Class OperatorTakeTimed.TakeSubscriber<T>