multiplex

Apr 16, 2018

Changes in this version

+ var ErrInvalidState = errors.New("received an unexpected message from the peer")

+ var ErrTwoInitiators = errors.New("two initiators")

Sep 3, 2017

Changes in this version

+ var ReceiveTimeout = 5 * time.Second

Aug 18, 2017

Changes in this version

+ const Message

+ const Reset

type Stream

+ func (s *Stream) Reset() error

Jul 30, 2017

Changes in this version

+ var ErrShutdown = errors.New("session shut down")

Feb 16, 2017

Changes in this version

+ const CloseLocal

Nov 23, 2016

Changes in this version

+ var MaxMessageSize = 1 << 20

Nov 22, 2016

Changes in this version

type Stream

+ func (s *Stream) SetDeadline(t time.Time) error

+ func (s *Stream) SetReadDeadline(t time.Time) error

+ func (s *Stream) SetWriteDeadline(t time.Time) error

May 2, 2016

Changes in this version

+ const Close

+ const Initiator

+ const NewStream

+ const Receiver

+ const Unknown

+ func DecodeVarint(r *bufio.Reader) (x uint64, n int, err error)

+ func EncodeVarint(x uint64) []byte

+ type Multiplex struct

+ func NewMultiplex(con io.ReadWriteCloser, initiator bool) *Multiplex

+ func (m *Multiplex) Accept() (*Stream, error)

+ func (mp *Multiplex) Close() error

+ func (mp *Multiplex) IsClosed() bool

+ func (mp *Multiplex) NewNamedStream(name string) *Stream

+ func (mp *Multiplex) NewStream() *Stream

+ type Stream struct

+ func (s *Stream) Close() error

+ func (s *Stream) Name() string

+ func (s *Stream) Read(b []byte) (int, error)

+ func (s *Stream) Write(b []byte) (int, error)