Function Test_Observable_AverageFloat32_Parallel_Error

observable_operator_test.go:105–111

(t *testing.T)

}

func Test_Observable_AverageFloat32_Parallel_Error(t *testing.T) {
	defer goleak.VerifyNone(t)
	ctx, cancel := context.WithCancel(context.Background())
	defer cancel()
	Assert(ctx, t, testObservable(ctx, "x").AverageFloat32(WithContext(ctx), WithCPUPool()),
		HasAnError())
}

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