multiplex

Dec 1, 2022

Changes in this version

+ type ConnID uint32

+ const LowestConnID

+ const PluginServiceConn

+ const RuntimeServiceConn

+ type Mux interface

+ Close func() error

+ Dialer func(ConnID) func(string, string) (net.Conn, error)

+ Listen func(ConnID) (net.Listener, error)

+ Open func(ConnID) (net.Conn, error)

+ Trunk func() net.Conn

+ Unblock func()

+ func Multiplex(trunk net.Conn, options ...Option) Mux

+ type Option func(*mux)

+ func WithBlockedRead() Option

+ func WithReadQueueLength(length int) Option