Function Test_Connectable_IterableSlice_Single

factory_connectable_test.go:215–222

(t *testing.T)

}

func Test_Connectable_IterableSlice_Single(t *testing.T) {
	defer goleak.VerifyNone(t)
	ctx, cancel := context.WithCancel(context.Background())
	defer cancel()
	obs := &ObservableImpl{iterable: newSliceIterable([]Item{Of(1), Of(2), Of(3)},
		WithPublishStrategy(), WithContext(ctx))}
	testConnectableSingle(t, obs)
}

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