@Test public void rejectSyncFusion() { UnicastProcessor<Object> p = UnicastProcessor.create(); TestSubscriber<Object> ts = SubscriberFusion.newTest(QueueFuseable.SYNC); p.subscribe(ts); SubscriberFusion.assertFusion(ts, QueueFuseable.NONE); }
@CheckReturnValue @NonNull public static <T> UnicastProcessor<T> create() { return new UnicastProcessor<T>(bufferSize()); }
UnicastProcessor extends FlowableProcessor<T> { @CheckReturnValue @NonNull public static <T> UnicastProcessor<T> create() { return new UnicastProcessor<T>(bufferSize()); } }
UnicastProcessor extends FlowableProcessor<T> { @CheckReturnValue @NonNull public static <T> UnicastProcessor<T> create() { return new UnicastProcessor<T>(bufferSize()); } UnicastProcessor(int capacityHint);   UnicastProcessor(int capacityHint, Runnable onTerminate);   UnicastProcessor(int capacityHint, Runnable onTerminate, boolean delayError); }
UnicastProcessor extends FlowableProcessor<T> { @CheckReturnValue @NonNull public static <T> UnicastProcessor<T> create() { return new UnicastProcessor<T>(bufferSize()); } UnicastProcessor(int capacityHint);   UnicastProcessor(int capacityHint, Runnable onTerminate);   UnicastProcessor(int capacityHint, Runnable onTerminate, boolean delayError); @CheckReturnValue @NonNull static UnicastProcessor<T> create(); @CheckReturnValue @NonNull static UnicastProcessor<T> create(int capacityHint); @CheckReturnValue @Experimental @NonNull static UnicastProcessor<T> create(boolean delayError); @CheckReturnValue @NonNull static UnicastProcessor<T> create(int capacityHint, Runnable onCancelled); @CheckReturnValue @Experimental @NonNull static UnicastProcessor<T> create(int capacityHint, Runnable onCancelled, boolean delayError); @Override void onSubscribe(Subscription s); @Override void onNext(T t); @Override void onError(Throwable t); @Override void onComplete(); @Override boolean hasSubscribers(); @Override @Nullable Throwable getThrowable(); @Override boolean hasComplete(); @Override boolean hasThrowable(); }
UnicastProcessor extends FlowableProcessor<T> { @CheckReturnValue @NonNull public static <T> UnicastProcessor<T> create() { return new UnicastProcessor<T>(bufferSize()); } UnicastProcessor(int capacityHint);   UnicastProcessor(int capacityHint, Runnable onTerminate);   UnicastProcessor(int capacityHint, Runnable onTerminate, boolean delayError); @CheckReturnValue @NonNull static UnicastProcessor<T> create(); @CheckReturnValue @NonNull static UnicastProcessor<T> create(int capacityHint); @CheckReturnValue @Experimental @NonNull static UnicastProcessor<T> create(boolean delayError); @CheckReturnValue @NonNull static UnicastProcessor<T> create(int capacityHint, Runnable onCancelled); @CheckReturnValue @Experimental @NonNull static UnicastProcessor<T> create(int capacityHint, Runnable onCancelled, boolean delayError); @Override void onSubscribe(Subscription s); @Override void onNext(T t); @Override void onError(Throwable t); @Override void onComplete(); @Override boolean hasSubscribers(); @Override @Nullable Throwable getThrowable(); @Override boolean hasComplete(); @Override boolean hasThrowable();  }