ctcp

type AsyncTcpListener struct {
	// contains filtered or unexported fields
}

type AsyncTcpSender struct {
	// contains filtered or unexported fields
}

type TcpListener interface {
	Init(addr string) error
	Listen(handler func(conn net.Conn)) error
	Close() bool
	Addr() net.Addr
}

type TcpMessage struct {
	// contains filtered or unexported fields
}

type TcpSender interface {
	Init(remoteAddr string, timeout time.Duration) error
	Send(content string) error
	Receive(delim byte) <-chan TcpMessage
	Close() bool
	Addr() net.Addr
	RemoteAddr() net.Addr
}