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

Method Observe

iterable.go:5–5  ·  view source on GitHub ↗
(opts ...Option)

Source from the content-addressed store, hash-verified

3// Iterable is the basic type that can be observed.
4type Iterable interface {
5 Observe(opts ...Option) <-chan Item
6}

Callers 15

ObserveMethod · 0.65
ErrorMethod · 0.65
ErrorsMethod · 0.65
FlatMapMethod · 0.65
JoinMethod · 0.65
ObserveMethod · 0.65
SampleMethod · 0.65
SequenceEqualMethod · 0.65
StartWithMethod · 0.65
ZipFromIterableMethod · 0.65
AmbFunction · 0.65
CombineLatestFunction · 0.65

Implementers 11

rangeIterableiterable_range.go
channelIterableiterable_channel.go
factoryIterableiterable_factory.go
createIterableiterable_create.go
OptionalSingleImploptionalsingle.go
ObservableImplobservable.go
justIterableiterable_just.go
eventSourceIterableiterable_eventsource.go
sliceIterableiterable_slice.go
deferIterableiterable_defer.go
SingleImplsingle.go

Calls

no outgoing calls

Tested by 15

testConnectableSingleFunction · 0.52
testConnectableComposedFunction · 0.52
Test_Observable_ObserveFunction · 0.52
Test_Observable_TimestampFunction · 0.52
Test_Observable_ErrorFunction · 0.52
Test_Observable_WindowWithCountFunction · 0.52
Test_Observable_WindowWithCount_ZeroCountFunction · 0.52
Test_Observable_WindowWithCount_ObservableErrorFunction · 0.52
Test_Observable_WindowWithTimeOrCountFunction · 0.52
Test_FromChannel_SimpleCapacityFunction · 0.52
Test_FromChannel_ComposedCapacityFunction · 0.52
Test_Just_SimpleCapacityFunction · 0.52