Function echo_StartServer

tests/echo_test.go:47–75

(context *echoContext)

)

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

	context.Acceptor = peer.NewGenericPeer(context.Protocol+".Acceptor", context.Protocol+"server", context.Address, queue)

	proc.BindProcessorHandler(context.Acceptor, context.Processor, func(ev cellnet.Event) {

		switch msg := ev.Message().(type) {
		case *cellnet.SessionAccepted:
			fmt.Println("server accepted")
		case *TestEchoACK:

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

			ev.Session().Send(&TestEchoACK{
				Msg:   msg.Msg,
				Value: msg.Value,
			})

		case *cellnet.SessionClosed:
			fmt.Println("session closed: ", ev.Session().ID())
		}

	})

	context.Acceptor.Start()

	queue.StartLoop()
}

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