test_class.file: rxjava/src/test/java/io/reactivex/processors/UnicastProcessorTest.java
test_class.identifier: UnicastProcessorTest
test_class.superclass: extends FlowableProcessorTest<Object>
test_case.body: @Test(expected = IllegalArgumentException.class)
      public void zeroCapacityHint() {
          UnicastProcessor.create(0);
      }
test_case.class_method_signature: UnicastProcessorTest.zeroCapacityHint()
test_case.full_signature: @Test(expected = IllegalArgumentException.class) public void zeroCapacityHint()
test_case.identifier: zeroCapacityHint
test_case.invocations: create
test_case.modifiers: @Test(expected = IllegalArgumentException.class) public
test_case.parameters: ()
test_case.return: void
test_case.signature: void zeroCapacityHint()
focal_class.declarator: queue
focal_class.modifier: final
focal_class.original_string: final SpscLinkedArrayQueue<T> queue;
focal_class.type: SpscLinkedArrayQueue<T>
focal_class.var_name: queue
focal_class.declarator: onTerminate
focal_class.modifier: final
focal_class.original_string: final AtomicReference<Runnable> onTerminate;
focal_class.type: AtomicReference<Runnable>
focal_class.var_name: onTerminate
focal_class.declarator: delayError
focal_class.modifier: final
focal_class.original_string: final boolean delayError;
focal_class.type: boolean
focal_class.var_name: delayError
focal_class.declarator: done
focal_class.modifier: volatile
focal_class.original_string: volatile boolean done;
focal_class.type: boolean
focal_class.var_name: done
focal_class.declarator: error
focal_class.original_string: Throwable error;
focal_class.type: Throwable
focal_class.var_name: error
focal_class.declarator: actual
focal_class.modifier: final
focal_class.original_string: final AtomicReference<Subscriber<? super T>> actual;
focal_class.type: AtomicReference<Subscriber<? super T>>
focal_class.var_name: actual
focal_class.declarator: cancelled
focal_class.modifier: volatile
focal_class.original_string: volatile boolean cancelled;
focal_class.type: boolean
focal_class.var_name: cancelled
focal_class.declarator: once
focal_class.modifier: final
focal_class.original_string: final AtomicBoolean once;
focal_class.type: AtomicBoolean
focal_class.var_name: once
focal_class.declarator: wip
focal_class.modifier: final
focal_class.original_string: final BasicIntQueueSubscription<T> wip;
focal_class.type: BasicIntQueueSubscription<T>
focal_class.var_name: wip
focal_class.declarator: requested
focal_class.modifier: final
focal_class.original_string: final AtomicLong requested;
focal_class.type: AtomicLong
focal_class.var_name: requested
focal_class.declarator: enableOperatorFusion
focal_class.original_string: boolean enableOperatorFusion;
focal_class.type: boolean
focal_class.var_name: enableOperatorFusion
focal_class.file: rxjava/src/main/java/io/reactivex/processors/UnicastProcessor.java
focal_class.identifier: UnicastProcessor
focal_class.class_method_signature: UnicastProcessor.create()
focal_class.full_signature: @CheckReturnValue @NonNull public static UnicastProcessor<T> create()
focal_class.identifier: create
focal_class.modifiers: @CheckReturnValue @NonNull public static
focal_class.parameters: ()
focal_class.return: UnicastProcessor<T>
focal_class.signature: UnicastProcessor<T> create()
focal_class.class_method_signature: UnicastProcessor.create(int capacityHint)
focal_class.full_signature: @CheckReturnValue @NonNull public static UnicastProcessor<T> create(int capacityHint)
focal_class.identifier: create
focal_class.modifiers: @CheckReturnValue @NonNull public static
focal_class.parameters: (int capacityHint)
focal_class.return: UnicastProcessor<T>
focal_class.signature: UnicastProcessor<T> create(int capacityHint)
focal_class.class_method_signature: UnicastProcessor.create(boolean delayError)
focal_class.full_signature: @CheckReturnValue @Experimental @NonNull public static UnicastProcessor<T> create(boolean delayError)
focal_class.identifier: create
focal_class.modifiers: @CheckReturnValue @Experimental @NonNull public static
focal_class.parameters: (boolean delayError)
focal_class.return: UnicastProcessor<T>
focal_class.signature: UnicastProcessor<T> create(boolean delayError)
focal_class.class_method_signature: UnicastProcessor.create(int capacityHint, Runnable onCancelled)
focal_class.full_signature: @CheckReturnValue @NonNull public static UnicastProcessor<T> create(int capacityHint, Runnable onCancelled)
focal_class.identifier: create
focal_class.modifiers: @CheckReturnValue @NonNull public static
focal_class.parameters: (int capacityHint, Runnable onCancelled)
focal_class.return: UnicastProcessor<T>
focal_class.signature: UnicastProcessor<T> create(int capacityHint, Runnable onCancelled)
focal_class.class_method_signature: UnicastProcessor.create(int capacityHint, Runnable onCancelled, boolean delayError)
focal_class.full_signature: @CheckReturnValue @Experimental @NonNull public static UnicastProcessor<T> create(int capacityHint, Runnable onCancelled, boolean delayError)
focal_class.identifier: create
focal_class.modifiers: @CheckReturnValue @Experimental @NonNull public static
focal_class.parameters: (int capacityHint, Runnable onCancelled, boolean delayError)
focal_class.return: UnicastProcessor<T>
focal_class.signature: UnicastProcessor<T> create(int capacityHint, Runnable onCancelled, boolean delayError)
focal_class.class_method_signature: UnicastProcessor.UnicastProcessor(int capacityHint)
focal_class.full_signature:   UnicastProcessor(int capacityHint)
focal_class.identifier: UnicastProcessor
focal_class.parameters: (int capacityHint)
focal_class.signature:  UnicastProcessor(int capacityHint)
focal_class.class_method_signature: UnicastProcessor.UnicastProcessor(int capacityHint, Runnable onTerminate)
focal_class.full_signature:   UnicastProcessor(int capacityHint, Runnable onTerminate)
focal_class.identifier: UnicastProcessor
focal_class.parameters: (int capacityHint, Runnable onTerminate)
focal_class.signature:  UnicastProcessor(int capacityHint, Runnable onTerminate)
focal_class.class_method_signature: UnicastProcessor.UnicastProcessor(int capacityHint, Runnable onTerminate, boolean delayError)
focal_class.full_signature:   UnicastProcessor(int capacityHint, Runnable onTerminate, boolean delayError)
focal_class.identifier: UnicastProcessor
focal_class.parameters: (int capacityHint, Runnable onTerminate, boolean delayError)
focal_class.signature:  UnicastProcessor(int capacityHint, Runnable onTerminate, boolean delayError)
focal_class.class_method_signature: UnicastProcessor.doTerminate()
focal_class.full_signature:  void doTerminate()
focal_class.identifier: doTerminate
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void doTerminate()
focal_class.class_method_signature: UnicastProcessor.drainRegular(Subscriber<? super T> a)
focal_class.full_signature:  void drainRegular(Subscriber<? super T> a)
focal_class.identifier: drainRegular
focal_class.parameters: (Subscriber<? super T> a)
focal_class.return: void
focal_class.signature: void drainRegular(Subscriber<? super T> a)
focal_class.class_method_signature: UnicastProcessor.drainFused(Subscriber<? super T> a)
focal_class.full_signature:  void drainFused(Subscriber<? super T> a)
focal_class.identifier: drainFused
focal_class.parameters: (Subscriber<? super T> a)
focal_class.return: void
focal_class.signature: void drainFused(Subscriber<? super T> a)
focal_class.class_method_signature: UnicastProcessor.drain()
focal_class.full_signature:  void drain()
focal_class.identifier: drain
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void drain()
focal_class.class_method_signature: UnicastProcessor.checkTerminated(boolean failFast, boolean d, boolean empty, Subscriber<? super T> a, SpscLinkedArrayQueue<T> q)
focal_class.full_signature:  boolean checkTerminated(boolean failFast, boolean d, boolean empty, Subscriber<? super T> a, SpscLinkedArrayQueue<T> q)
focal_class.identifier: checkTerminated
focal_class.parameters: (boolean failFast, boolean d, boolean empty, Subscriber<? super T> a, SpscLinkedArrayQueue<T> q)
focal_class.return: boolean
focal_class.signature: boolean checkTerminated(boolean failFast, boolean d, boolean empty, Subscriber<? super T> a, SpscLinkedArrayQueue<T> q)
focal_class.class_method_signature: UnicastProcessor.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: UnicastProcessor.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: UnicastProcessor.onError(Throwable t)
focal_class.full_signature: @Override public void onError(Throwable t)
focal_class.identifier: onError
focal_class.modifiers: @Override public
focal_class.parameters: (Throwable t)
focal_class.return: void
focal_class.signature: void onError(Throwable t)
focal_class.class_method_signature: UnicastProcessor.onComplete()
focal_class.full_signature: @Override public void onComplete()
focal_class.identifier: onComplete
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void onComplete()
focal_class.class_method_signature: UnicastProcessor.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: UnicastProcessor.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: UnicastProcessor.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: UnicastProcessor.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: UnicastProcessor.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.superclass: extends FlowableProcessor<T>
focal_method.body: @CheckReturnValue
      @NonNull
      public static <T> UnicastProcessor<T> create() {
          return new UnicastProcessor<T>(bufferSize());
      }
focal_method.class_method_signature: UnicastProcessor.create()
focal_method.full_signature: @CheckReturnValue @NonNull public static UnicastProcessor<T> create()
focal_method.identifier: create
focal_method.invocations: bufferSize
focal_method.modifiers: @CheckReturnValue @NonNull public static
focal_method.parameters: ()
focal_method.return: UnicastProcessor<T>
focal_method.signature: UnicastProcessor<T> create()