writer

package

v0.333.2-candidate Latest Latest Go to latest Published: Aug 26, 2016 License: Apache-2.0 Imports: 3 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type FanIn interface {
	Write(data []byte) (int, error)
	Close() error
	AddSink(sink io.WriteCloser)
	AddSource(source io.Reader)
}

func NewFanIn() FanIn

type FanOut interface {
	Write(data []byte) (int, error)
	AddSink(sink io.Writer)
}

func NewFanOut() FanOut