test_class.declarator: testException = new Throwable()
test_class.modifier: private final
test_class.original_string: private final Throwable testException = new Throwable();
test_class.type: Throwable
test_class.var_name: testException
test_class.file: rxjava/src/test/java/io/reactivex/processors/ReplayProcessorTest.java
test_class.identifier: ReplayProcessorTest
test_class.superclass: extends FlowableProcessorTest<Object>
test_case.body: @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());
      }
test_case.class_method_signature: ReplayProcessorTest.hasSubscribers()
test_case.full_signature: @Test public void hasSubscribers()
test_case.identifier: hasSubscribers
test_case.invocations: create assertFalse hasSubscribers test assertTrue hasSubscribers cancel assertFalse hasSubscribers
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void hasSubscribers()
focal_class.declarator: EMPTY_ARRAY = new Object[0]
focal_class.modifier: private static final
focal_class.original_string: private static final Object[] EMPTY_ARRAY = new Object[0];
focal_class.type: Object[]
focal_class.var_name: EMPTY_ARRAY
focal_class.declarator: buffer
focal_class.modifier: final
focal_class.original_string: final ReplayBuffer<T> buffer;
focal_class.type: ReplayBuffer<T>
focal_class.var_name: buffer
focal_class.declarator: done
focal_class.original_string: boolean done;
focal_class.type: boolean
focal_class.var_name: done
focal_class.declarator: subscribers
focal_class.modifier: final
focal_class.original_string: final AtomicReference<ReplaySubscription<T>[]> subscribers;
focal_class.type: AtomicReference<ReplaySubscription<T>[]>
focal_class.var_name: subscribers
focal_class.declarator: EMPTY = new ReplaySubscription[0]
focal_class.modifier: @SuppressWarnings("rawtypes")
      static final
focal_class.original_string: @SuppressWarnings("rawtypes")
      static final ReplaySubscription[] EMPTY = new ReplaySubscription[0];
focal_class.type: ReplaySubscription[]
focal_class.var_name: EMPTY
focal_class.declarator: TERMINATED = new ReplaySubscription[0]
focal_class.modifier: @SuppressWarnings("rawtypes")
      static final
focal_class.original_string: @SuppressWarnings("rawtypes")
      static final ReplaySubscription[] TERMINATED = new ReplaySubscription[0];
focal_class.type: ReplaySubscription[]
focal_class.var_name: TERMINATED
focal_class.file: rxjava/src/main/java/io/reactivex/processors/ReplayProcessor.java
focal_class.identifier: ReplayProcessor
focal_class.class_method_signature: ReplayProcessor.create()
focal_class.full_signature: @CheckReturnValue @NonNull public static ReplayProcessor<T> create()
focal_class.identifier: create
focal_class.modifiers: @CheckReturnValue @NonNull public static
focal_class.parameters: ()
focal_class.return: ReplayProcessor<T>
focal_class.signature: ReplayProcessor<T> create()
focal_class.class_method_signature: ReplayProcessor.create(int capacityHint)
focal_class.full_signature: @CheckReturnValue @NonNull public static ReplayProcessor<T> create(int capacityHint)
focal_class.identifier: create
focal_class.modifiers: @CheckReturnValue @NonNull public static
focal_class.parameters: (int capacityHint)
focal_class.return: ReplayProcessor<T>
focal_class.signature: ReplayProcessor<T> create(int capacityHint)
focal_class.class_method_signature: ReplayProcessor.createWithSize(int maxSize)
focal_class.full_signature: @CheckReturnValue @NonNull public static ReplayProcessor<T> createWithSize(int maxSize)
focal_class.identifier: createWithSize
focal_class.modifiers: @CheckReturnValue @NonNull public static
focal_class.parameters: (int maxSize)
focal_class.return: ReplayProcessor<T>
focal_class.signature: ReplayProcessor<T> createWithSize(int maxSize)
focal_class.class_method_signature: ReplayProcessor.createUnbounded()
focal_class.full_signature: static ReplayProcessor<T> createUnbounded()
focal_class.identifier: createUnbounded
focal_class.modifiers: static
focal_class.parameters: ()
focal_class.return: ReplayProcessor<T>
focal_class.signature: ReplayProcessor<T> createUnbounded()
focal_class.class_method_signature: ReplayProcessor.createWithTime(long maxAge, TimeUnit unit, Scheduler scheduler)
focal_class.full_signature: @CheckReturnValue @NonNull public static ReplayProcessor<T> createWithTime(long maxAge, TimeUnit unit, Scheduler scheduler)
focal_class.identifier: createWithTime
focal_class.modifiers: @CheckReturnValue @NonNull public static
focal_class.parameters: (long maxAge, TimeUnit unit, Scheduler scheduler)
focal_class.return: ReplayProcessor<T>
focal_class.signature: ReplayProcessor<T> createWithTime(long maxAge, TimeUnit unit, Scheduler scheduler)
focal_class.class_method_signature: ReplayProcessor.createWithTimeAndSize(long maxAge, TimeUnit unit, Scheduler scheduler, int maxSize)
focal_class.full_signature: @CheckReturnValue @NonNull public static ReplayProcessor<T> createWithTimeAndSize(long maxAge, TimeUnit unit, Scheduler scheduler, int maxSize)
focal_class.identifier: createWithTimeAndSize
focal_class.modifiers: @CheckReturnValue @NonNull public static
focal_class.parameters: (long maxAge, TimeUnit unit, Scheduler scheduler, int maxSize)
focal_class.return: ReplayProcessor<T>
focal_class.signature: ReplayProcessor<T> createWithTimeAndSize(long maxAge, TimeUnit unit, Scheduler scheduler, int maxSize)
focal_class.class_method_signature: ReplayProcessor.ReplayProcessor(ReplayBuffer<T> buffer)
focal_class.full_signature: @SuppressWarnings("unchecked")  ReplayProcessor(ReplayBuffer<T> buffer)
focal_class.identifier: ReplayProcessor
focal_class.modifiers: @SuppressWarnings("unchecked")
focal_class.parameters: (ReplayBuffer<T> buffer)
focal_class.signature:  ReplayProcessor(ReplayBuffer<T> buffer)
focal_class.class_method_signature: ReplayProcessor.subscribeActual(Subscriber<? super T> s)
focal_class.full_signature: @Override protected void subscribeActual(Subscriber<? super T> s)
focal_class.identifier: subscribeActual
focal_class.modifiers: @Override protected
focal_class.parameters: (Subscriber<? super T> s)
focal_class.return: void
focal_class.signature: void subscribeActual(Subscriber<? super T> s)
focal_class.class_method_signature: ReplayProcessor.onSubscribe(Subscription s)
focal_class.full_signature: @Override public void onSubscribe(Subscription s)
focal_class.identifier: onSubscribe
focal_class.modifiers: @Override public
focal_class.parameters: (Subscription s)
focal_class.return: void
focal_class.signature: void onSubscribe(Subscription s)
focal_class.class_method_signature: ReplayProcessor.onNext(T t)
focal_class.full_signature: @Override public void onNext(T t)
focal_class.identifier: onNext
focal_class.modifiers: @Override public
focal_class.parameters: (T t)
focal_class.return: void
focal_class.signature: void onNext(T t)
focal_class.class_method_signature: ReplayProcessor.onError(Throwable t)
focal_class.full_signature: @SuppressWarnings("unchecked") @Override public void onError(Throwable t)
focal_class.identifier: onError
focal_class.modifiers: @SuppressWarnings("unchecked") @Override public
focal_class.parameters: (Throwable t)
focal_class.return: void
focal_class.signature: void onError(Throwable t)
focal_class.class_method_signature: ReplayProcessor.onComplete()
focal_class.full_signature: @SuppressWarnings("unchecked") @Override public void onComplete()
focal_class.identifier: onComplete
focal_class.modifiers: @SuppressWarnings("unchecked") @Override public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void onComplete()
focal_class.class_method_signature: ReplayProcessor.hasSubscribers()
focal_class.full_signature: @Override public boolean hasSubscribers()
focal_class.identifier: hasSubscribers
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean hasSubscribers()
focal_class.class_method_signature: ReplayProcessor.subscriberCount()
focal_class.full_signature:  int subscriberCount()
focal_class.identifier: subscriberCount
focal_class.parameters: ()
focal_class.return: int
focal_class.signature: int subscriberCount()
focal_class.class_method_signature: ReplayProcessor.getThrowable()
focal_class.full_signature: @Override @Nullable public Throwable getThrowable()
focal_class.identifier: getThrowable
focal_class.modifiers: @Override @Nullable public
focal_class.parameters: ()
focal_class.return: Throwable
focal_class.signature: Throwable getThrowable()
focal_class.class_method_signature: ReplayProcessor.cleanupBuffer()
focal_class.full_signature: @Experimental public void cleanupBuffer()
focal_class.identifier: cleanupBuffer
focal_class.modifiers: @Experimental public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void cleanupBuffer()
focal_class.class_method_signature: ReplayProcessor.getValue()
focal_class.full_signature: public T getValue()
focal_class.identifier: getValue
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: T
focal_class.signature: T getValue()
focal_class.class_method_signature: ReplayProcessor.getValues()
focal_class.full_signature: public Object[] getValues()
focal_class.identifier: getValues
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: Object[]
focal_class.signature: Object[] getValues()
focal_class.class_method_signature: ReplayProcessor.getValues(T[] array)
focal_class.full_signature: public T[] getValues(T[] array)
focal_class.identifier: getValues
focal_class.modifiers: public
focal_class.parameters: (T[] array)
focal_class.return: T[]
focal_class.signature: T[] getValues(T[] array)
focal_class.class_method_signature: ReplayProcessor.hasComplete()
focal_class.full_signature: @Override public boolean hasComplete()
focal_class.identifier: hasComplete
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean hasComplete()
focal_class.class_method_signature: ReplayProcessor.hasThrowable()
focal_class.full_signature: @Override public boolean hasThrowable()
focal_class.identifier: hasThrowable
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean hasThrowable()
focal_class.class_method_signature: ReplayProcessor.hasValue()
focal_class.full_signature: public boolean hasValue()
focal_class.identifier: hasValue
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean hasValue()
focal_class.class_method_signature: ReplayProcessor.size()
focal_class.full_signature:  int size()
focal_class.identifier: size
focal_class.parameters: ()
focal_class.return: int
focal_class.signature: int size()
focal_class.class_method_signature: ReplayProcessor.add(ReplaySubscription<T> rs)
focal_class.full_signature:  boolean add(ReplaySubscription<T> rs)
focal_class.identifier: add
focal_class.parameters: (ReplaySubscription<T> rs)
focal_class.return: boolean
focal_class.signature: boolean add(ReplaySubscription<T> rs)
focal_class.class_method_signature: ReplayProcessor.remove(ReplaySubscription<T> rs)
focal_class.full_signature: @SuppressWarnings("unchecked") void remove(ReplaySubscription<T> rs)
focal_class.identifier: remove
focal_class.modifiers: @SuppressWarnings("unchecked")
focal_class.parameters: (ReplaySubscription<T> rs)
focal_class.return: void
focal_class.signature: void remove(ReplaySubscription<T> rs)
focal_class.superclass: extends FlowableProcessor<T>
focal_method.body: @Override
      public boolean hasSubscribers() {
          return subscribers.get().length != 0;
      }
focal_method.class_method_signature: ReplayProcessor.hasSubscribers()
focal_method.full_signature: @Override public boolean hasSubscribers()
focal_method.identifier: hasSubscribers
focal_method.invocations: get
focal_method.modifiers: @Override public
focal_method.parameters: ()
focal_method.return: boolean
focal_method.signature: boolean hasSubscribers()