Method testAction5

src/test/java/rx/util/async/AsyncTest.java:270–289

()

    }

    @Test
    public void testAction5() {
        final AtomicInteger value = new AtomicInteger();
        Action5<Integer, Integer, Integer, Integer, Integer> action = new Action5<Integer, Integer, Integer, Integer, Integer>() {
            @Override
            public void call(Integer t1, Integer t2, Integer t3, Integer t4, Integer t5) {
                value.set(t1 | t2 | t3 | t4 | t5);
            }
        };

        Async.toAsync(action, Schedulers.immediate())
                .call(1, 2, 4, 8, 16)
                .subscribe(new TestObserver<Object>(observer));

        verify(observer, never()).onError(any(Throwable.class));
        verify(observer, times(1)).onNext(null);
        verify(observer, times(1)).onCompleted();

        Assert.assertEquals(31, value.get());
    }

    @Test
    public void testAction5Error() {