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

Method getPool

options.go:17–17  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

15 toPropagate() bool
16 isEagerObservation() bool
17 getPool() (bool, int)
18 buildChannel() chan Item
19 buildContext(parent context.Context) context.Context
20 getBackPressureStrategy() BackpressureStrategy

Callers 4

observableFunction · 0.65
singleFunction · 0.65
optionalSingleFunction · 0.65
runParallelFunction · 0.65

Implementers 1

funcOptionoptions.go

Calls

no outgoing calls

Tested by

no test coverage detected