testutils

Documentation

Index

• type PipeListener
  • 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)

Types

type PipeListener

type PipeListener struct {
	// contains filtered or unexported fields
}

PipeListener is a listener with an unbuffered pipe. Each write will complete only once the other side reads. It should only be created using NewPipeListener.

func NewPipeListener

func NewPipeListener() *PipeListener

NewPipeListener creates a new pipe listener.

func (*PipeListener) Accept

func (p *PipeListener) Accept() (net.Conn, error)

Accept accepts a connection.

func (*PipeListener) Addr

func (p *PipeListener) Addr() net.Addr

Addr returns a pipe addr.

func (*PipeListener) Close

func (p *PipeListener) Close() error

Close closes the listener.

func (*PipeListener) Dialer

func (p *PipeListener) Dialer() func(string, time.Duration) (net.Conn, error)

Dialer dials a connection.