stream_packet

package

v0.9.2 Latest Latest Go to latest Published: Jan 10, 2023 License: Apache-2.0 Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

Session wraps a stream in a session.

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

NewSession builds a new session.

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

RecvMsg tries to receive a message on the wire.

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

SendMsg tries to send a message on the wire.