type Stream …
type Framer …
func NewRawStream(conn net.Conn) Stream { … }
type rawStream …
func (s *rawStream) Read(ctx context.Context) (Message, int64, error) { … }
func (s *rawStream) Write(ctx context.Context, msg Message) (int64, error) { … }
func (s *rawStream) Close() error { … }
func NewHeaderStream(conn net.Conn) Stream { … }
type headerStream …
func (s *headerStream) Read(ctx context.Context) (Message, int64, error) { … }
func (s *headerStream) Write(ctx context.Context, msg Message) (int64, error) { … }
func (s *headerStream) Close() error { … }