Versions in this module Expand all Collapse all v1 v1.0.4 Oct 5, 2022 v1.0.3 Apr 29, 2022 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