stream

type ReadStream interface {
	// Receive receives the next result
	Receive() (Result, bool)

	// Drain drains the stream
	Drain()
}

type Result struct {
	Value interface{}
	Error error
}

type Stream interface {
	ReadStream
	WriteStream
}

type WriteStream interface {
	// Send sends an output on the stream
	Send(out Result)

	// Result sends a result on the stream
	Result(value interface{}, err error)

	// Value sends a value on the stream
	Value(value interface{})

	// Error sends an error on the stream
	Error(err error)

	// Close closes the stream
	Close()
}