The highest tagged major version is v4.

connctx

package

v0.14.1 Latest Latest Go to latest Published: Nov 30, 2022 License: MIT Imports: 7 Imported by: 6

Details

Package connctx wraps net.Conn using context.Context.

This section is empty.

View Source

var ErrClosing = errors.New("use of closed network connection")

ErrClosing is returned on Write to closed connection.

func Pipe() (ConnCtx, ConnCtx)

Pipe creates piped pair of ConnCtx.

type ConnCtx interface {
	Reader
	Writer
	io.Closer
	LocalAddr() net.Addr
	RemoteAddr() net.Addr
	Conn() net.Conn
}

ConnCtx is a wrapper of net.Conn using context.Context.

func New(conn net.Conn) ConnCtx

New creates a new ConnCtx wrapping given net.Conn.

type ReadWriter interface {
	Reader
	Writer
}

ReadWriter is a composite of ReadWriter.

type Reader interface {
	ReadContext(context.Context, []byte) (int, error)
}

Reader is an interface for context controlled reader.

type Writer interface {
	WriteContext(context.Context, []byte) (int, error)
}

Writer is an interface for context controlled writer.