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

Method Reduce

observable.go:61–61  ·  view source on GitHub ↗
(apply Func2, opts ...Option)

Source from the content-addressed store, hash-verified

59 OnErrorReturn(resumeFunc ErrorFunc, opts ...Option) Observable
60 OnErrorReturnItem(resume interface{}, opts ...Option) Observable
61 Reduce(apply Func2, opts ...Option) OptionalSingle
62 Repeat(count int64, frequency Duration, opts ...Option) Observable
63 Retry(count int, shouldRetry func(error) bool, opts ...Option) Observable
64 Run(opts ...Option) Disposed

Callers 9

Test_Observable_ReduceFunction · 0.65
Test_Observable_Reduce_EmptyFunction · 0.65
Test_Observable_Reduce_ErrorFunction · 0.65
Test_Observable_Reduce_ReturnErrorFunction · 0.65
Test_Observable_Reduce_ParallelFunction · 0.65
Test_Observable_Reduce_Parallel_ErrorFunction · 0.65
Test_Observable_Reduce_Parallel_WithErrorStrategyFunction · 0.65
Benchmark_Reduce_SequentialFunction · 0.65
Benchmark_Reduce_ParallelFunction · 0.65

Implementers 1

ObservableImplobservable.go

Calls

no outgoing calls

Tested by 9

Test_Observable_ReduceFunction · 0.52
Test_Observable_Reduce_EmptyFunction · 0.52
Test_Observable_Reduce_ErrorFunction · 0.52
Test_Observable_Reduce_ReturnErrorFunction · 0.52
Test_Observable_Reduce_ParallelFunction · 0.52
Test_Observable_Reduce_Parallel_ErrorFunction · 0.52
Test_Observable_Reduce_Parallel_WithErrorStrategyFunction · 0.52
Benchmark_Reduce_SequentialFunction · 0.52
Benchmark_Reduce_ParallelFunction · 0.52