iomux

Documentation

Overview

Package iomux provides simple goroutine safe I/O primitives.

Index

• type Socket
  • func (sck *Socket) Read(p []byte) (int, error)
  • func (sck *Socket) Recv() ([]byte, error)
  • func (sck *Socket) Send(p []byte) error
  • func (sck *Socket) Write(p []byte) (int, error)
• type Writer
  • func NewWriter(w io.Writer) *Writer
  • func (w *Writer) Close() error
  • func (w *Writer) String() string
  • func (w *Writer) Write(p []byte) (int, error)

Types

type Socket

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

func (*Socket) Read

func (sck *Socket) Read(p []byte) (int, error)

func (*Socket) Recv

func (sck *Socket) Recv() ([]byte, error)

func (*Socket) Send

func (sck *Socket) Send(p []byte) error

func (*Socket) Write

func (sck *Socket) Write(p []byte) (int, error)

type Writer

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

Writer is a goroutine-safe io.Writer.

func NewWriter

func NewWriter(w io.Writer) *Writer

func (*Writer) Close

func (w *Writer) Close() error

func (*Writer) String

func (w *Writer) String() string

func (*Writer) Write

func (w *Writer) Write(p []byte) (int, error)