smux

Nov 29, 2016

Changes in this version

type Session

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

type Stream

+ func (s *Stream) LocalAddr() net.Addr

+ func (s *Stream) RemoteAddr() net.Addr

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

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

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

Sep 7, 2016

Changes in this version

+ func VerifyConfig(config *Config) error

+ type Config struct

+ KeepAliveInterval time.Duration

+ KeepAliveTimeout time.Duration

+ MaxFrameSize int

+ MaxReceiveBuffer int

+ func DefaultConfig() *Config

+ type Frame struct

+ func (f *Frame) MarshalBinary() ([]byte, error)

+ func (f *Frame) UnmarshalBinary(bts []byte) error

+ type Session struct

+ func Client(conn io.ReadWriteCloser, config *Config) (*Session, error)

+ func Server(conn io.ReadWriteCloser, config *Config) (*Session, error)

+ func (s *Session) AcceptStream() (*Stream, error)

+ func (s *Session) Close() (err error)

+ func (s *Session) IsClosed() bool

+ func (s *Session) NumStreams() int

+ func (s *Session) OpenStream() (*Stream, error)

+ type Stream struct

+ func (s *Stream) Close() error

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

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