stream

Documentation

Index

• type MessageStream
  • func NewMessageStream(conn net.Conn) *MessageStream
  • func (this *MessageStream) ReadLine() ([]byte, error)
  • func (this *MessageStream) ReadMessage() (*message.Message, error)

Types

type MessageStream

type MessageStream struct {
	Conn net.Conn
	// contains filtered or unexported fields
}

func NewMessageStream

func NewMessageStream(conn net.Conn) *MessageStream

func (*MessageStream) ReadLine

func (this *MessageStream) ReadLine() ([]byte, error)

func (*MessageStream) ReadMessage

func (this *MessageStream) ReadMessage() (*message.Message, error)