Function Test_Connectable_IterableJust_Composed

factory_connectable_test.go:185–193

(t *testing.T)

}

func Test_Connectable_IterableJust_Composed(t *testing.T) {
	defer goleak.VerifyNone(t)
	ctx, cancel := context.WithCancel(context.Background())
	defer cancel()
	obs := &ObservableImpl{
		iterable: newJustIterable(1, 2, 3)(WithPublishStrategy(), WithContext(ctx)),
	}
	testConnectableComposed(t, obs)
}

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