class ReplaySubject extends Subject<T, T> {

    @SuppressWarnings("unchecked")
    @Experimental
    public Object[] getValues() {
        return state.toArray((T[])EMPTY_ARRAY);
    }

      ReplaySubject(OnSubscribe<T> onSubscribe, SubjectSubscriptionManager<T> ssm, ReplayState<T, ?> state);

}