framedstream

package

v0.57.21 Latest Latest Go to latest Published: Oct 2, 2026 License: Apache-2.0 Imports: 8 Imported by: 0

Details

This section is empty.

View Source

var MaxMessageSize uint32 = 10 * 1024 * 1024 // 10MB

MaxMessageSize is the max message size in bytes.

This section is empty.

type Stream struct {
	// contains filtered or unexported fields
}

Stream wraps an io.ReadWriteCloser to implement rpcstream.RpcStream. Uses LittleEndian uint32 length-prefix framing for messages.

func New(ctx context.Context, rwc io.ReadWriteCloser) *Stream

New creates a new framed Stream.

func (s *Stream) Close() error

Close closes the stream.

func (s *Stream) CloseSend() error

CloseSend signals to the remote that we will no longer send any messages.

func (s *Stream) Context() context.Context

Context returns the stream context.

func (s *Stream) MsgRecv(msg srpc.Message) error

MsgRecv receives a protobuf message from the remote.

func (s *Stream) MsgSend(msg srpc.Message) error

MsgSend sends a protobuf message to the remote.

func (s *Stream) Recv() (*rpcstream.RpcStreamPacket, error)

Recv receives an RpcStreamPacket.

func (s *Stream) RecvRaw() ([]byte, error)

RecvRaw reads a length-prefixed frame and returns the raw bytes.

func (s *Stream) Send(pkt *rpcstream.RpcStreamPacket) error

Send sends an RpcStreamPacket.

func (s *Stream) SendRaw(data []byte) error

SendRaw writes raw bytes with length-prefix framing.