Class OnSubscribeReduce<T>