### Question:
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);  }### Answer:
@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]); }