Versions in this module Expand all Collapse all v0 v0.1.0 Sep 12, 2019 Changes in this version + type Finite struct + C <-chan interface{} + func NewFinite(maxSize int, flush FlushFunc) *Finite + func (c *Finite) Add(x interface{}) error + func (c *Finite) Close() error + func (c *Finite) Err() (err error) + func (c *Finite) Flush() + func (c *Finite) FlushAllButN(N int) + func (c *Finite) Len() (n int) + func (c *Finite) SetError(err error) + type FlushFunc func([]interface{}) error