MCPcopy Index your code
hub / github.com/ReactiveX/RxGo / parseOptions

Function parseOptions

options.go:109–115  ·  view source on GitHub ↗
(opts ...Option)

Source from the content-addressed store, hash-verified

107}
108
109func parseOptions(opts ...Option) Option {
110 o := new(funcOption)
111 for _, opt := range opts {
112 opt.apply(o)
113 }
114 return o
115}
116
117// WithBufferedChannel allows to configure the capacity of a buffered channel.
118func WithBufferedChannel(capacity int) Option {

Callers 15

ObserveMethod · 0.85
ObserveMethod · 0.85
newCreateIterableFunction · 0.85
ObserveMethod · 0.85
GetMethod · 0.85
RunMethod · 0.85
BackOffRetryMethod · 0.85
DoOnCompletedMethod · 0.85
DoOnErrorMethod · 0.85
DoOnNextMethod · 0.85
ErrorMethod · 0.85
ErrorsMethod · 0.85

Calls 1

applyMethod · 0.65

Tested by

no test coverage detected