protocol

type Connection interface {
	ReadMsg() ([]byte, error)
	WriteMsg(data []byte) error
	Close() error
	Addr() string
}

type FlowProtocol struct {
	Proto
	// contains filtered or unexported fields
}

type Proto interface {
	// Pack writes the Message into the connection.
	// NOTE: Make sure to write only once or there will be package contamination!
	Pack([]byte) ([]byte, error)
	// Read bytes from the connection.
	ReadMsg() ([]byte, error)
}

type Protocol interface {
	// ListenAndServe turns on the listening service.
	ListenAndServe(port int64, onConnect func(conn Connection)) error
	// Dial connects with the socket of the destination address.
	Dial(addr string) (Connection, error)
}

type Session struct {
	Conn     Connection
	ClientId string
}