MCPcopy Create free account
hub / github.com/ReactiveX/RxGo / BufferWithCount

Method BufferWithCount

observable.go:26–26  ·  view source on GitHub ↗
(count int, opts ...Option)

Source from the content-addressed store, hash-verified

24 AverageInt64(opts ...Option) Single
25 BackOffRetry(backOffCfg backoff.BackOff, opts ...Option) Observable
26 BufferWithCount(count int, opts ...Option) Observable
27 BufferWithTime(timespan Duration, opts ...Option) Observable
28 BufferWithTimeOrCount(timespan Duration, count int, opts ...Option) Observable
29 Connect(ctx context.Context) (context.Context, Disposable)

Callers 4

Test_Observable_BufferWithCountFunction · 0.65
Test_Observable_BufferWithCount_IncompleteLastItemFunction · 0.65
Test_Observable_BufferWithCount_ErrorFunction · 0.65
Test_Observable_BufferWithCount_InputErrorFunction · 0.65

Implementers 1

ObservableImplobservable.go

Calls

no outgoing calls

Tested by 4

Test_Observable_BufferWithCountFunction · 0.52
Test_Observable_BufferWithCount_IncompleteLastItemFunction · 0.52
Test_Observable_BufferWithCount_ErrorFunction · 0.52
Test_Observable_BufferWithCount_InputErrorFunction · 0.52