stream

Documentation

Index

• func New(orb *orbit.Orbit) interface{}
• type Buffer
  • func NewBuffer(orb *orbit.Orbit, buf *bytes.Buffer) *Buffer
  • func (this *Buffer) Close() error
  • func (this *Buffer) Consume(r io.Reader)
  • func (this *Buffer) End()
  • func (this *Buffer) Pipe(w io.Writer)
  • func (this *Buffer) Read(p []byte) (n int, e error)
  • func (this *Buffer) Write(p []byte) (n int, e error)
• type Module
  • func (this *Module) Buffer() *Buffer
• type ReadCloser
  • func NewReadCloser(orb *orbit.Orbit, stm io.ReadCloser) *ReadCloser
  • func (this *ReadCloser) Close() error
  • func (this *ReadCloser) End()
  • func (this *ReadCloser) Pipe(w io.Writer)
  • func (this *ReadCloser) Read(p []byte) (n int, e error)
  • func (this *ReadCloser) String() string
• type Reader
  • func NewReader(orb *orbit.Orbit, stm io.Reader) *Reader
  • func (this *Reader) Close() error
  • func (this *Reader) End()
  • func (this *Reader) Pipe(w io.Writer)
  • func (this *Reader) Read(p []byte) (n int, e error)
  • func (this *Reader) String() string
• type WriteCloser
  • func NewWriteCloser(orb *orbit.Orbit, stm io.WriteCloser) *WriteCloser
  • func (this *WriteCloser) Close() error
  • func (this *WriteCloser) Consume(r io.Reader)
  • func (this *WriteCloser) End()
  • func (this *WriteCloser) Write(p []byte) (n int, e error)
• type Writer
  • func NewWriter(orb *orbit.Orbit, stm io.Writer) *Writer
  • func (this *Writer) Close() error
  • func (this *Writer) Consume(r io.Reader)
  • func (this *Writer) End()
  • func (this *Writer) Write(p []byte) (n int, e error)

Functions

func New

func New(orb *orbit.Orbit) interface{}

Types

type Buffer

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

func NewBuffer

func NewBuffer(orb *orbit.Orbit, buf *bytes.Buffer) *Buffer

func (*Buffer) Close

func (this *Buffer) Close() error

func (*Buffer) Consume

func (this *Buffer) Consume(r io.Reader)

func (*Buffer) End

func (this *Buffer) End()

func (*Buffer) Pipe

func (this *Buffer) Pipe(w io.Writer)

func (*Buffer) Read

func (this *Buffer) Read(p []byte) (n int, e error)

func (*Buffer) Write

func (this *Buffer) Write(p []byte) (n int, e error)

type Module

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

func (*Module) Buffer

func (this *Module) Buffer() *Buffer

type ReadCloser

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

func NewReadCloser

func NewReadCloser(orb *orbit.Orbit, stm io.ReadCloser) *ReadCloser

func (*ReadCloser) Close

func (this *ReadCloser) Close() error

func (*ReadCloser) End

func (this *ReadCloser) End()

func (*ReadCloser) Pipe

func (this *ReadCloser) Pipe(w io.Writer)

func (*ReadCloser) Read

func (this *ReadCloser) Read(p []byte) (n int, e error)

func (*ReadCloser) String

func (this *ReadCloser) String() string

type Reader

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

func NewReader

func NewReader(orb *orbit.Orbit, stm io.Reader) *Reader

func (*Reader) Close

func (this *Reader) Close() error

func (*Reader) End

func (this *Reader) End()

func (*Reader) Pipe

func (this *Reader) Pipe(w io.Writer)

func (*Reader) Read

func (this *Reader) Read(p []byte) (n int, e error)

func (*Reader) String

func (this *Reader) String() string

type WriteCloser

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

func NewWriteCloser

func NewWriteCloser(orb *orbit.Orbit, stm io.WriteCloser) *WriteCloser

func (*WriteCloser) Close

func (this *WriteCloser) Close() error

func (*WriteCloser) Consume

func (this *WriteCloser) Consume(r io.Reader)

func (*WriteCloser) End

func (this *WriteCloser) End()

func (*WriteCloser) Write

func (this *WriteCloser) Write(p []byte) (n int, e error)

type Writer

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

func NewWriter

func NewWriter(orb *orbit.Orbit, stm io.Writer) *Writer

func (*Writer) Close

func (this *Writer) Close() error

func (*Writer) Consume

func (this *Writer) Consume(r io.Reader)

func (*Writer) End

func (this *Writer) End()

func (*Writer) Write

func (this *Writer) Write(p []byte) (n int, e error)