Function Test_Connectable_IterableChannel_Composed

factory_connectable_test.go:31–44

(t *testing.T)

}

func Test_Connectable_IterableChannel_Composed(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()),
	}
	testConnectableComposed(t, obs)
}

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