Function echo_StartClient

tests/echo_test.go:77–107

(echoContext *echoContext)

}

func echo_StartClient(echoContext *echoContext) {
	queue := cellnet.NewEventQueue()

	p := peer.NewGenericPeer(echoContext.Protocol+".Connector", echoContext.Protocol+"client", echoContext.Address, queue)

	proc.BindProcessorHandler(p, echoContext.Processor, func(ev cellnet.Event) {

		switch msg := ev.Message().(type) {
		case *cellnet.SessionConnected:
			fmt.Println("client connected")
			ev.Session().Send(&TestEchoACK{
				Msg:   "hello",
				Value: 1234,
			})
		case *TestEchoACK:

			fmt.Printf("client recv %+v\n", msg)

			echoContext.Tester.Done(1)

		case *cellnet.SessionClosed:
			fmt.Println("client closed")
		}
	})

	p.Start()

	queue.StartLoop()

	echoContext.Tester.WaitAndExpect("not recv data", 1)
}

func runEcho(t *testing.T, index int) {