@Test public void hasSubscribers() { ReplayProcessor<Integer> rp = ReplayProcessor.create(); assertFalse(rp.hasSubscribers()); TestSubscriber<Integer> ts = rp.test(); assertTrue(rp.hasSubscribers()); ts.cancel(); assertFalse(rp.hasSubscribers()); }
@Override public boolean hasSubscribers() { return subscribers.get().length != 0; }
ReplayProcessor extends FlowableProcessor<T> { @Override public boolean hasSubscribers() { return subscribers.get().length != 0; } }
ReplayProcessor extends FlowableProcessor<T> { @Override public boolean hasSubscribers() { return subscribers.get().length != 0; } @SuppressWarnings("unchecked")  ReplayProcessor(ReplayBuffer<T> buffer); }
ReplayProcessor extends FlowableProcessor<T> { @Override public boolean hasSubscribers() { return subscribers.get().length != 0; } @SuppressWarnings("unchecked")  ReplayProcessor(ReplayBuffer<T> buffer); @CheckReturnValue @NonNull static ReplayProcessor<T> create(); @CheckReturnValue @NonNull static ReplayProcessor<T> create(int capacityHint); @CheckReturnValue @NonNull static ReplayProcessor<T> createWithSize(int maxSize); @CheckReturnValue @NonNull static ReplayProcessor<T> createWithTime(long maxAge, TimeUnit unit, Scheduler scheduler); @CheckReturnValue @NonNull static ReplayProcessor<T> createWithTimeAndSize(long maxAge, TimeUnit unit, Scheduler scheduler, int maxSize); @Override void onSubscribe(Subscription s); @Override void onNext(T t); @SuppressWarnings("unchecked") @Override void onError(Throwable t); @SuppressWarnings("unchecked") @Override void onComplete(); @Override boolean hasSubscribers(); @Override @Nullable Throwable getThrowable(); @Experimental void cleanupBuffer(); T getValue(); Object[] getValues(); T[] getValues(T[] array); @Override boolean hasComplete(); @Override boolean hasThrowable(); boolean hasValue(); }
ReplayProcessor extends FlowableProcessor<T> { @Override public boolean hasSubscribers() { return subscribers.get().length != 0; } @SuppressWarnings("unchecked")  ReplayProcessor(ReplayBuffer<T> buffer); @CheckReturnValue @NonNull static ReplayProcessor<T> create(); @CheckReturnValue @NonNull static ReplayProcessor<T> create(int capacityHint); @CheckReturnValue @NonNull static ReplayProcessor<T> createWithSize(int maxSize); @CheckReturnValue @NonNull static ReplayProcessor<T> createWithTime(long maxAge, TimeUnit unit, Scheduler scheduler); @CheckReturnValue @NonNull static ReplayProcessor<T> createWithTimeAndSize(long maxAge, TimeUnit unit, Scheduler scheduler, int maxSize); @Override void onSubscribe(Subscription s); @Override void onNext(T t); @SuppressWarnings("unchecked") @Override void onError(Throwable t); @SuppressWarnings("unchecked") @Override void onComplete(); @Override boolean hasSubscribers(); @Override @Nullable Throwable getThrowable(); @Experimental void cleanupBuffer(); T getValue(); Object[] getValues(); T[] getValues(T[] array); @Override boolean hasComplete(); @Override boolean hasThrowable(); boolean hasValue();  }