transport

type HandshakeFunc func(Peer) error

type Message struct {
	Peer    Peer
	Payload []byte
}

type Peer interface {
	Close() error
	Send([]byte) error
}

type Receiver func(io.Reader) ([]byte, error)

type TCPPeer struct {
	net.Conn
}

type TCPTransport struct {
	Receive   Receiver
	Handshake HandshakeFunc
	// contains filtered or unexported fields
}

type Transport interface {
	Addr() string
	Listen() error
	Consume() <-chan Message
	Close() error
}