Method BufferWithCount

observable_operator.go:400–411

BufferWithCount returns an Observable that emits buffers of items it collects from the source Observable. The resulting Observable emits buffers every skip items, each containing a slice of count items. When the source Observable completes or encounters an error, the resulting Observable emits the c

(count int, opts ...Option)

// the resulting Observable emits the current buffer and propagates
// the notification from the source Observable.
func (o *ObservableImpl) BufferWithCount(count int, opts ...Option) Observable {
	if count <= 0 {
		return Thrown(IllegalInputError{error: "count must be positive"})
	}

	return observable(o.parent, o, func() operator {
		return &bufferWithCountOperator{
			count:  count,
			buffer: make([]interface{}, count),
		}
	}, true, false, opts...)
}

type bufferWithCountOperator struct {
	count  int