Struct sharedBufferChannel

shared_buffer.go:11–16

sharedBufferChannel implements SimpleChannel and is created by the public SharedBuffer type below

//sharedBufferChannel implements SimpleChannel and is created by the public
//SharedBuffer type below
type sharedBufferChannel struct {
	in     chan interface{}
	out    chan interface{}
	buf    *queue.Queue
	closed bool
}

func (sch *sharedBufferChannel) In() chan<- interface{} {
	return sch.in