stream

Documentation

Index

• Constants
• func ReadProtoMessage(r io.Reader, msg proto.Message) error
• func WriteProtoMessage(w io.Writer, msg proto.Message) error

Constants

const MAX_MESSAGE_SIZE = 1024 * 1024

Functions

func ReadProtoMessage

func ReadProtoMessage(r io.Reader, msg proto.Message) error

ReadProtoMessage reads a proto message from a stream with a max size of 1MB.

func WriteProtoMessage

func WriteProtoMessage(w io.Writer, msg proto.Message) error

WriteProtoMessage writes a proto message to a stream.