Golang test.NewSignalTester函数代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› Go›Go教程

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Golang中github.com/davyxu/cellnet/test.NewSignalTester函数的典型用法代码示例。如果您正苦于以下问题：Golang NewSignalTester函数的具体用法？Golang NewSignalTester怎么用？Golang NewSignalTester使用的例子？那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。

在下文中一共展示了NewSignalTester函数的7个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Golang代码示例。

示例1: TestTimer

func TestTimer(t *testing.T) {

	signal := test.NewSignalTester(t)

	pipe := cellnet.NewEventPipe()

	evq := pipe.AddQueue()

	pipe.Start()

	const testTimes = 3

	var count int = testTimes

	cellnet.NewTimer(evq, time.Second, func(t *cellnet.Timer) {
		log.Debugln("timer 1 sec tick")

		signal.Done(1)

		count--

		if count == 0 {
			t.Stop()
			signal.Done(2)
		}
	})

	for i := 0; i < testTimes; i++ {
		signal.WaitAndExpect(1, "timer not tick")
	}

	signal.WaitAndExpect(2, "timer not stop")

}

开发者ID:CaiGuaiNi，项目名称:cellnet，代码行数:34，代码来源:timer_test.go

示例2: TestRPC

func TestRPC(t *testing.T) {

	signal = test.NewSignalTester(t)

	server()

	client()

}

开发者ID:faquiiR，项目名称:cellnet，代码行数:9，代码来源:rpc_test.go

示例3: TestClose

func TestClose(t *testing.T) {

	signal = test.NewSignalTester(t)

	runServer()

	testConnActiveClose()
	testRecvDisconnected()
}

开发者ID:FengJiaQi，项目名称:cellnet，代码行数:9，代码来源:sendclose_test.go

示例4: TestGate

func TestGate(t *testing.T) {

	signal = test.NewSignalTester(t)

	routerServer()
	backendServer()
	client()

}

开发者ID:CaiGuaiNi，项目名称:cellnet，代码行数:9，代码来源:router_test.go

示例5: TestIO

func TestIO(t *testing.T) {

	// 屏蔽socket层的调试日志
	golog.SetLevelByString("socket", "error")

	signal = test.NewSignalTester(t)

	// 超时时间为测试时间延迟一会
	signal.SetTimeout((benchmarkSeconds + 5) * time.Second)

	server()

	for i := 0; i < clientCount; i++ {
		go client()
	}

	signal.WaitAndExpect(1, "recv time out")

}

开发者ID:davyxu，项目名称:cellnet，代码行数:19，代码来源:io_test.go

示例6: TestDelay

func TestDelay(t *testing.T) {

	signal := test.NewSignalTester(t)

	pipe := cellnet.NewEventPipe()

	evq := pipe.AddQueue()

	pipe.Start()

	log.Debugln("delay 1 sec begin")

	evq.DelayPostData(time.Second, func() {

		log.Debugln("delay done")
		signal.Done(1)
	})

	signal.WaitAndExpect(1, "delay not work")
}

开发者ID:CaiGuaiNi，项目名称:cellnet，代码行数:20，代码来源:timer_test.go

示例7: TestMongoDB

func TestMongoDB(t *testing.T) {

	signal = test.NewSignalTester(t)

	db()
}

开发者ID:bobbyzhu，项目名称:cellnet，代码行数:6，代码来源:mgo_test.go

注：本文中的github.com/davyxu/cellnet/test.NewSignalTester函数示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。