Function Test_Observable_AverageInt8

observable_operator_test.go:168–176

(t *testing.T)

}

func Test_Observable_AverageInt8(t *testing.T) {
	defer goleak.VerifyNone(t)
	ctx, cancel := context.WithCancel(context.Background())
	defer cancel()
	Assert(ctx, t, testObservable(ctx, int8(1), int8(2), int8(3)).AverageInt8(), HasItem(int8(2)))
	Assert(ctx, t, testObservable(ctx, int8(1), int8(20)).AverageInt8(), HasItem(int8(10)))
	Assert(ctx, t, Empty().AverageInt8(), HasItem(0))
	Assert(ctx, t, testObservable(ctx, 1.1, 2.2, 3.3).AverageInt8(), HasAnError())
}

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