@Test
public void testActionN() {

    final AtomicInteger value = new AtomicInteger();
    ActionN action = new ActionN() {
        @Override
        public void call(Object... args) {
            int i = 0;
            for (Object o : args) {
                i = i | (Integer) o;
            }
            value.set(i);
        }
    };
    Async.toAsync(action, Schedulers.immediate())
            .call(1, 2, 4, 8, 16, 32, 64, 128, 256, 512)
            .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(1023, value.get());
}