stream_packet

Documentation

Index

• type Session
  • func NewSession(stream io.ReadWriteCloser, maxMessageSize uint32) *Session
  • func (s *Session) RecvMsg(msg proto.Message) error
  • func (s *Session) SendMsg(msg proto.Message) error

Types

type Session

type Session struct {
	io.ReadWriteCloser
	// contains filtered or unexported fields
}

Session wraps a stream in a session.

func NewSession

func NewSession(
	stream io.ReadWriteCloser,
	maxMessageSize uint32,
) *Session

NewSession builds a new session.

func (*Session) RecvMsg

func (s *Session) RecvMsg(msg proto.Message) error

RecvMsg tries to receive a message on the wire.

func (*Session) SendMsg

func (s *Session) SendMsg(msg proto.Message) error

SendMsg tries to send a message on the wire.