@Test
public void unicastSubscriptionBadRequest() {

    UnicastProcessor<Integer> us = UnicastProcessor.create(false);
    UnicastProcessor<Integer>.UnicastQueueSubscription usc = us.new UnicastQueueSubscription();
    List<Throwable> errors = TestHelper.trackPluginErrors();
    try {
        usc.request(-1);
        TestHelper.assertError(errors, 0, IllegalArgumentException.class);
    } finally {
        RxJavaPlugins.reset();
    }
}