Class BlockingFlowableMostRecent.MostRecentSubscriber<T>