Versions in this module Expand all Collapse all v1 v1.33.1 Sep 1, 2020 Changes in this version + const DefaultChanBufferSize + func StatusErrEqual(err1, err2 error) bool + type Channel struct + func NewChannel() *Channel + func NewChannelWithSize(bufSize int) *Channel + func (cwt *Channel) Receive(ctx context.Context) (interface{}, error) + func (cwt *Channel) Replace(value interface{}) + func (cwt *Channel) Send(value interface{}) + type PipeListener struct + func NewPipeListener() *PipeListener + func (p *PipeListener) Accept() (net.Conn, error) + func (p *PipeListener) Addr() net.Addr + func (p *PipeListener) Close() error + func (p *PipeListener) Dialer() func(string, time.Duration) (net.Conn, error)
Go to main page