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/subjects/ReplaySubjectTest.java
test_class.identifier: ReplaySubjectTest
test_class.superclass: extends SubjectTest<Integer>
test_case.body: @Test
      public void createWithTimeAndSizeInvalidCapacity() {
          try {
              ReplaySubject.createWithTimeAndSize(1, TimeUnit.DAYS, Schedulers.computation(), -99);
              fail("Didn't throw IllegalArgumentException");
          } catch (IllegalArgumentException ex) {
              assertEquals("maxSize > 0 required but it was -99", ex.getMessage());
          }
      }
test_case.class_method_signature: ReplaySubjectTest.createWithTimeAndSizeInvalidCapacity()
test_case.full_signature: @Test public void createWithTimeAndSizeInvalidCapacity()
test_case.identifier: createWithTimeAndSizeInvalidCapacity
test_case.invocations: createWithTimeAndSize computation fail assertEquals getMessage
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void createWithTimeAndSizeInvalidCapacity()
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: observers
focal_class.modifier: final
focal_class.original_string: final AtomicReference<ReplayDisposable<T>[]> observers;
focal_class.type: AtomicReference<ReplayDisposable<T>[]>
focal_class.var_name: observers
focal_class.declarator: EMPTY = new ReplayDisposable[0]
focal_class.modifier: @SuppressWarnings("rawtypes")
      static final
focal_class.original_string: @SuppressWarnings("rawtypes")
      static final ReplayDisposable[] EMPTY = new ReplayDisposable[0];
focal_class.type: ReplayDisposable[]
focal_class.var_name: EMPTY
focal_class.declarator: TERMINATED = new ReplayDisposable[0]
focal_class.modifier: @SuppressWarnings("rawtypes")
      static final
focal_class.original_string: @SuppressWarnings("rawtypes")
      static final ReplayDisposable[] TERMINATED = new ReplayDisposable[0];
focal_class.type: ReplayDisposable[]
focal_class.var_name: TERMINATED
focal_class.declarator: done
focal_class.original_string: boolean done;
focal_class.type: boolean
focal_class.var_name: done
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.file: rxjava/src/main/java/io/reactivex/subjects/ReplaySubject.java
focal_class.identifier: ReplaySubject
focal_class.class_method_signature: ReplaySubject.create()
focal_class.full_signature: @CheckReturnValue @NonNull public static ReplaySubject<T> create()
focal_class.identifier: create
focal_class.modifiers: @CheckReturnValue @NonNull public static
focal_class.parameters: ()
focal_class.return: ReplaySubject<T>
focal_class.signature: ReplaySubject<T> create()
focal_class.class_method_signature: ReplaySubject.create(int capacityHint)
focal_class.full_signature: @CheckReturnValue @NonNull public static ReplaySubject<T> create(int capacityHint)
focal_class.identifier: create
focal_class.modifiers: @CheckReturnValue @NonNull public static
focal_class.parameters: (int capacityHint)
focal_class.return: ReplaySubject<T>
focal_class.signature: ReplaySubject<T> create(int capacityHint)
focal_class.class_method_signature: ReplaySubject.createWithSize(int maxSize)
focal_class.full_signature: @CheckReturnValue @NonNull public static ReplaySubject<T> createWithSize(int maxSize)
focal_class.identifier: createWithSize
focal_class.modifiers: @CheckReturnValue @NonNull public static
focal_class.parameters: (int maxSize)
focal_class.return: ReplaySubject<T>
focal_class.signature: ReplaySubject<T> createWithSize(int maxSize)
focal_class.class_method_signature: ReplaySubject.createUnbounded()
focal_class.full_signature: static ReplaySubject<T> createUnbounded()
focal_class.identifier: createUnbounded
focal_class.modifiers: static
focal_class.parameters: ()
focal_class.return: ReplaySubject<T>
focal_class.signature: ReplaySubject<T> createUnbounded()
focal_class.class_method_signature: ReplaySubject.createWithTime(long maxAge, TimeUnit unit, Scheduler scheduler)
focal_class.full_signature: @CheckReturnValue @NonNull public static ReplaySubject<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: ReplaySubject<T>
focal_class.signature: ReplaySubject<T> createWithTime(long maxAge, TimeUnit unit, Scheduler scheduler)
focal_class.class_method_signature: ReplaySubject.createWithTimeAndSize(long maxAge, TimeUnit unit, Scheduler scheduler, int maxSize)
focal_class.full_signature: @CheckReturnValue @NonNull public static ReplaySubject<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: ReplaySubject<T>
focal_class.signature: ReplaySubject<T> createWithTimeAndSize(long maxAge, TimeUnit unit, Scheduler scheduler, int maxSize)
focal_class.class_method_signature: ReplaySubject.ReplaySubject(ReplayBuffer<T> buffer)
focal_class.full_signature: @SuppressWarnings("unchecked")  ReplaySubject(ReplayBuffer<T> buffer)
focal_class.identifier: ReplaySubject
focal_class.modifiers: @SuppressWarnings("unchecked")
focal_class.parameters: (ReplayBuffer<T> buffer)
focal_class.signature:  ReplaySubject(ReplayBuffer<T> buffer)
focal_class.class_method_signature: ReplaySubject.subscribeActual(Observer<? super T> observer)
focal_class.full_signature: @Override protected void subscribeActual(Observer<? super T> observer)
focal_class.identifier: subscribeActual
focal_class.modifiers: @Override protected
focal_class.parameters: (Observer<? super T> observer)
focal_class.return: void
focal_class.signature: void subscribeActual(Observer<? super T> observer)
focal_class.class_method_signature: ReplaySubject.onSubscribe(Disposable s)
focal_class.full_signature: @Override public void onSubscribe(Disposable s)
focal_class.identifier: onSubscribe
focal_class.modifiers: @Override public
focal_class.parameters: (Disposable s)
focal_class.return: void
focal_class.signature: void onSubscribe(Disposable s)
focal_class.class_method_signature: ReplaySubject.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: ReplaySubject.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: ReplaySubject.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: ReplaySubject.hasObservers()
focal_class.full_signature: @Override public boolean hasObservers()
focal_class.identifier: hasObservers
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean hasObservers()
focal_class.class_method_signature: ReplaySubject.observerCount()
focal_class.full_signature:  int observerCount()
focal_class.identifier: observerCount
focal_class.parameters: ()
focal_class.return: int
focal_class.signature: int observerCount()
focal_class.class_method_signature: ReplaySubject.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: ReplaySubject.getValue()
focal_class.full_signature: @Nullable public T getValue()
focal_class.identifier: getValue
focal_class.modifiers: @Nullable public
focal_class.parameters: ()
focal_class.return: T
focal_class.signature: T getValue()
focal_class.class_method_signature: ReplaySubject.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: ReplaySubject.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: ReplaySubject.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: ReplaySubject.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: ReplaySubject.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: ReplaySubject.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: ReplaySubject.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: ReplaySubject.add(ReplayDisposable<T> rs)
focal_class.full_signature:  boolean add(ReplayDisposable<T> rs)
focal_class.identifier: add
focal_class.parameters: (ReplayDisposable<T> rs)
focal_class.return: boolean
focal_class.signature: boolean add(ReplayDisposable<T> rs)
focal_class.class_method_signature: ReplaySubject.remove(ReplayDisposable<T> rs)
focal_class.full_signature: @SuppressWarnings("unchecked") void remove(ReplayDisposable<T> rs)
focal_class.identifier: remove
focal_class.modifiers: @SuppressWarnings("unchecked")
focal_class.parameters: (ReplayDisposable<T> rs)
focal_class.return: void
focal_class.signature: void remove(ReplayDisposable<T> rs)
focal_class.class_method_signature: ReplaySubject.terminate(Object terminalValue)
focal_class.full_signature: @SuppressWarnings("unchecked") ReplayDisposable<T>[] terminate(Object terminalValue)
focal_class.identifier: terminate
focal_class.modifiers: @SuppressWarnings("unchecked")
focal_class.parameters: (Object terminalValue)
focal_class.return: ReplayDisposable<T>[]
focal_class.signature: ReplayDisposable<T>[] terminate(Object terminalValue)
focal_class.superclass: extends Subject<T>
focal_method.body: @CheckReturnValue
      @NonNull
      public static <T> ReplaySubject<T> createWithTimeAndSize(long maxAge, TimeUnit unit, Scheduler scheduler, int maxSize) {
          return new ReplaySubject<T>(new SizeAndTimeBoundReplayBuffer<T>(maxSize, maxAge, unit, scheduler));
      }
focal_method.class_method_signature: ReplaySubject.createWithTimeAndSize(long maxAge, TimeUnit unit, Scheduler scheduler, int maxSize)
focal_method.full_signature: @CheckReturnValue @NonNull public static ReplaySubject<T> createWithTimeAndSize(long maxAge, TimeUnit unit, Scheduler scheduler, int maxSize)
focal_method.identifier: createWithTimeAndSize
focal_method.modifiers: @CheckReturnValue @NonNull public static
focal_method.parameters: (long maxAge, TimeUnit unit, Scheduler scheduler, int maxSize)
focal_method.return: ReplaySubject<T>
focal_method.signature: ReplaySubject<T> createWithTimeAndSize(long maxAge, TimeUnit unit, Scheduler scheduler, int maxSize)