Function Test_Connectable_IterableChannel_Single

factory_connectable_test.go:16–29

(t *testing.T)

)

func Test_Connectable_IterableChannel_Single(t *testing.T) {
	defer goleak.VerifyNone(t)
	ch := make(chan Item, 10)
	go func() {
		ch <- Of(1)
		ch <- Of(2)
		ch <- Of(3)
		close(ch)
	}()
	obs := &ObservableImpl{
		iterable: newChannelIterable(ch, WithPublishStrategy()),
	}
	testConnectableSingle(t, obs)
}

func Test_Connectable_IterableChannel_Composed(t *testing.T) {
	defer goleak.VerifyNone(t)