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

Function testObservable

util_test.go:33–35  ·  view source on GitHub ↗
(ctx context.Context, items ...interface{})

Source from the content-addressed store, hash-verified

31}
32
33func testObservable(ctx context.Context, items ...interface{}) Observable {
34 return FromChannel(channelValue(ctx, items...))
35}

Callers 15

Test_Observable_All_FalseFunction · 0.85
Test_Observable_All_Parallel_FalseFunction · 0.85
Test_Observable_All_Parallel_ErrorFunction · 0.85
Test_Observable_AverageFloat32Function · 0.85
Test_Observable_AverageFloat32_ErrorFunction · 0.85
Test_Observable_AverageFloat32_ParallelFunction · 0.85
Test_Observable_AverageFloat32_Parallel_ErrorFunction · 0.85
Test_Observable_AverageFloat64Function · 0.85
Test_Observable_AverageFloat64_ErrorFunction · 0.85
Test_Observable_AverageFloat64_ParallelFunction · 0.85
Test_Observable_AverageFloat64_Parallel_ErrorFunction · 0.85
Test_Observable_AverageIntFunction · 0.85

Calls 2

FromChannelFunction · 0.85
channelValueFunction · 0.85

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…