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

Method Retry

observable.go:63–63  ·  view source on GitHub ↗
(count int, shouldRetry func(error) bool, opts ...Option)

Source from the content-addressed store, hash-verified

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
65 Sample(iterable Iterable, opts ...Option) Observable
66 Scan(apply Func2, opts ...Option) Observable

Callers 4

BackOffRetryMethod · 0.65
Test_Observable_RetryFunction · 0.65
Test_Observable_Retry_Error_ShouldRetryFunction · 0.65
Test_Observable_Retry_Error_ShouldNotRetryFunction · 0.65

Implementers 1

ObservableImplobservable.go

Calls

no outgoing calls

Tested by 3

Test_Observable_RetryFunction · 0.52
Test_Observable_Retry_Error_ShouldRetryFunction · 0.52
Test_Observable_Retry_Error_ShouldNotRetryFunction · 0.52