@Test(timeout = 60000) public void testSequentialSubscriptions() throws Exception { String[] msgs = { "Hello1", "Hello2" }; rule.subject.onNext(msgs[0]); rule.subscribeAndAssertValues(rule.subject.take(1), msgs[0]); rule.subject.onNext(msgs[1]); rule.subscribeAndAssertValues(rule.subject.take(1), msgs[1]); }
@Override public void onNext(T t) { try { addNext(t); } catch (MissingBackpressureException e) { throw Exceptions.propagate(e); } }
UnicastBufferingSubject extends Subject<T, T> { @Override public void onNext(T t) { try { addNext(t); } catch (MissingBackpressureException e) { throw Exceptions.propagate(e); } } }
UnicastBufferingSubject extends Subject<T, T> { @Override public void onNext(T t) { try { addNext(t); } catch (MissingBackpressureException e) { throw Exceptions.propagate(e); } } protected  UnicastBufferingSubject(OnSubscribe<T> onSubscribe, State<T> state); }
UnicastBufferingSubject extends Subject<T, T> { @Override public void onNext(T t) { try { addNext(t); } catch (MissingBackpressureException e) { throw Exceptions.propagate(e); } } protected  UnicastBufferingSubject(OnSubscribe<T> onSubscribe, State<T> state); static UnicastBufferingSubject<T> create(long bufferSize); boolean isTerminated(); @Override boolean hasObservers(); @Override void onCompleted(); @Override void onError(Throwable e); @Override void onNext(T t); boolean offerNext(T next); }
UnicastBufferingSubject extends Subject<T, T> { @Override public void onNext(T t) { try { addNext(t); } catch (MissingBackpressureException e) { throw Exceptions.propagate(e); } } protected  UnicastBufferingSubject(OnSubscribe<T> onSubscribe, State<T> state); static UnicastBufferingSubject<T> create(long bufferSize); boolean isTerminated(); @Override boolean hasObservers(); @Override void onCompleted(); @Override void onError(Throwable e); @Override void onNext(T t); boolean offerNext(T next);  }