Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrStreamIDWrong = fmt.Errorf("wrong stream id") ErrStreamIDExpired = fmt.Errorf("expired stream id") ErrStreamIDReused = fmt.Errorf("stream id is be reused. %w", ErrStreamIDExpired) )
View Source
var (
ErrStreamOpenTimeout = fmt.Errorf("open stream timeout")
)
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client struct { ID string Endpoint string Conn net.Conn Timeout time.Duration // contains filtered or unexported fields }
func (*Client) HandleConn ¶
func (c *Client) HandleConn(stream io.ReadWriteCloser) (err error)
type StreamHook ¶
type StreamHook struct { Header StreamCh chan io.ReadWriteCloser // contains filtered or unexported fields }
Click to show internal directories.
Click to hide internal directories.