class ReplaySubject extends Subject<T, T> {

    @Experimental
    public int size() {
        return state.size();
    }

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

}