internal

Documentation

Index

• type ChanPipe
  • func (c ChanPipe) Read(p []byte) (n int, err error)
  • func (c ChanPipe) ReadString(s string) error
  • func (c ChanPipe) Write(p []byte) (n int, err error)
  • func (c ChanPipe) WriteString(s string) (n int, err error)
• type ConcBuffer
  • func (c *ConcBuffer) Reset()
  • func (c *ConcBuffer) String() string
  • func (c *ConcBuffer) Write(p []byte) (int, error)
  • func (c *ConcBuffer) WriteString(s string) (int, error)

Types

type ChanPipe

type ChanPipe chan []byte

ChanPipe is a very simple pipe that uses a single channel to move bytes around.

func (ChanPipe) Read

func (c ChanPipe) Read(p []byte) (n int, err error)

func (ChanPipe) ReadString

func (c ChanPipe) ReadString(s string) error

ReadString is an utility function that will keep reading from the pipe until the bytes from the supplied string are read.

func (ChanPipe) Write

func (c ChanPipe) Write(p []byte) (n int, err error)

func (ChanPipe) WriteString

func (c ChanPipe) WriteString(s string) (n int, err error)

type ConcBuffer

type ConcBuffer struct {
	sync.Mutex
	// contains filtered or unexported fields
}

ConcBuffer wraps a bytes.Buffer in a mutex so that concurrent writes to it don't upset the race detector.

func (*ConcBuffer) Reset

func (c *ConcBuffer) Reset()

func (*ConcBuffer) String

func (c *ConcBuffer) String() string

func (*ConcBuffer) Write

func (c *ConcBuffer) Write(p []byte) (int, error)

func (*ConcBuffer) WriteString

func (c *ConcBuffer) WriteString(s string) (int, error)