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

Function Test_Observable_Option_SimpleCapacity

observable_operator_option_test.go:45–49  ·  view source on GitHub ↗
(t *testing.T)

Source from the content-addressed store, hash-verified

43}
44
45func Test_Observable_Option_SimpleCapacity(t *testing.T) {
46 defer goleak.VerifyNone(t)
47 ch := Just(1)(WithBufferedChannel(5)).Observe()
48 assert.Equal(t, 5, cap(ch))
49}
50
51func Test_Observable_Option_ComposedCapacity(t *testing.T) {
52 defer goleak.VerifyNone(t)

Callers

nothing calls this directly

Calls 3

JustFunction · 0.85
WithBufferedChannelFunction · 0.85
ObserveMethod · 0.65

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…