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

Function Test_SendItems_SliceWithError

item_test.go:32–37  ·  view source on GitHub ↗
(t *testing.T)

Source from the content-addressed store, hash-verified

30}
31
32func Test_SendItems_SliceWithError(t *testing.T) {
33 defer goleak.VerifyNone(t)
34 ch := make(chan Item, 3)
35 go SendItems(context.Background(), ch, CloseChannel, []interface{}{1, errFoo, 3})
36 Assert(context.Background(), t, FromChannel(ch), HasItems(1, 3), HasError(errFoo))
37}
38
39func Test_Item_SendBlocking(t *testing.T) {
40 defer goleak.VerifyNone(t)

Callers

nothing calls this directly

Calls 5

SendItemsFunction · 0.85
AssertFunction · 0.85
FromChannelFunction · 0.85
HasItemsFunction · 0.85
HasErrorFunction · 0.85

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…