netpipe

Documentation

Index

• Variables
• func Pipe(maxSize int, addrs ...net.Addr) (net.Conn, net.Conn)

Variables

var ErrExceedMaxSize = fmt.Errorf("exceed max size")

var ErrPipeClosed = fmt.Errorf("pipe closed")

var ErrReadDeadline = fmt.Errorf("pipe read deadline exceeded")

var ErrWriteDeadline = fmt.Errorf("pipe write deadline exceeded")

Functions

func Pipe

func Pipe(maxSize int, addrs ...net.Addr) (net.Conn, net.Conn)

Pipe creates an async, in-memory, full duplex network connection; both ends implement the Conn interface. Reads on one end are matched with writes on the other, copying data directly between the two; there is an internal buffering of size.