@@ -0,0 +1,607 @@
+package rsc.processor;%0A%0Aimport java.util.concurrent.ConcurrentLinkedQueue;%0A%0Aimport org.junit.Test;%0A%0Aimport rsc.test.TestSubscriber;%0A%0Apublic class UnicastProcessorTest %7B%0A%0A    @Test%0A    public void secondSubscriberRejectedProperly() %7B%0A        %0A        UnicastProcessor%3CInteger%3E up = new UnicastProcessor%3C%3E(new ConcurrentLinkedQueue%3C%3E());%0A        %0A        up.subscribe();%0A        %0A        TestSubscriber%3CInteger%3E ts = new TestSubscriber%3C%3E();%0A        %0A        up.subscribe(ts);%0A        %0A        ts.assertNoValues()%0A        .assertError(IllegalStateException.class)%0A        .assertNotComplete();%0A        %0A    %7D%0A%7D

Add test fro UnicastProcessor rejecting second Subscriber properly