ioextends

Documentation

Index

• type Piped
  • func ReadPipe() *Piped
  • func (w *Piped) AddWriter(wr io.WriteCloser) error
  • func (w *Piped) Close() error
  • func (w *Piped) NewPipe() (io.ReadCloser, error)
  • func (w *Piped) Write(p []byte) (int, error)

Types

type Piped

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

func ReadPipe

func ReadPipe() *Piped

func (*Piped) AddWriter

func (w *Piped) AddWriter(wr io.WriteCloser) error

Add existing io.WriteCloser to list

func (*Piped) Close

func (w *Piped) Close() error

Close all writes, if io.WriteCloser.Close() returns an error, the loop will be stopped and this error will be returned, if no error occurs, return an io.EOF

func (*Piped) NewPipe

func (w *Piped) NewPipe() (io.ReadCloser, error)

create new ReadCloser

func (*Piped) Write

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

Write bytes to pipeds streams