dchan

type Chan interface {
	// Send event to a channel.
	Send(v stream.Event)
	// Receive event and closed flag from a channel.
	Recv() (stream.Event, bool)
	// Number of events in the channel buffer.
	Len() int
	// Maximum possible number of events in the channel buffer.
	Cap() int
	// Close the channel.
	Close()
	// Free the underlying resources of a closed channel.
	// Call this function after Close and before channel is empty.
	Done()
}