Function Test_Connectable_IterableChannel_Disposed

factory_connectable_test.go:46–64

(t *testing.T)

}

func Test_Connectable_IterableChannel_Disposed(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()),
	}
	ctx, cancel := context.WithTimeout(context.Background(), 50*time.Millisecond)
	defer cancel()
	_, disposable := obs.Connect(ctx)
	disposable()
	time.Sleep(50 * time.Millisecond)
	Assert(ctx, t, obs, IsEmpty())
}

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