rx/core/observablebase.py
def take_until_with_time(self, end_time) -> 'ObservableBase':
        """Takes elements for the specified duration until the specified end
        time, using the specified scheduler to run timers.

        Examples:
        1 - res = source.take_until_with_time(dt, [optional scheduler])
        2 - res = source.take_until_with_time(5000, [optional scheduler])

        Keyword Arguments:
        end_time -- {Number | Date} Time to stop taking elements from the source
            sequence. If this value is less than or equal to Date(), the
            result stream will complete immediately.
        scheduler -- {Scheduler} Scheduler to run the timer on.

        Returns an observable {Observable} sequence with the elements taken
        until the specified end time.
        """
        from ..operators.observable.takeuntilwithtime import take_until_with_time
        return take_until_with_time(self, end_time)
Takes elements for the specified duration until the specified end
        time, using the specified scheduler to run timers.

        Examples:
        1 - res = source.take_until_with_time(dt, [optional scheduler])
        2 - res = source.take_until_with_time(5000, [optional scheduler])

        Keyword Arguments:
        end_time -- {Number | Date} Time to stop taking elements from the source
            sequence. If this value is less than or equal to Date(), the
            result stream will complete immediately.
        scheduler -- {Scheduler} Scheduler to run the timer on.

        Returns an observable {Observable} sequence with the elements taken
        until the specified end time.
        
Takes elements for the specified duration until the specified end
time, using the specified scheduler to run timers.
Takes elements for the specified duration until the specified end time using the specified scheduler to run timers .
def take_until_with_time(self, end_time) -> 'ObservableBase':
        from ..operators.observable.takeuntilwithtime import take_until_with_time
        return take_until_with_time(self, end_time)
def take_until_with_time ( self , end_time ) -> 'ObservableBase' : from . . operators . observable . takeuntilwithtime import take_until_with_time return take_until_with_time ( self , end_time )
Takes elements for the specified duration until the specified end
time, using the specified scheduler to run timers.
Takes elements for the specified duration until the specified end time using the specified scheduler to run timers .
"""Takes elements for the specified duration until the specified end
        time, using the specified scheduler to run timers.

        Examples:
        1 - res = source.take_until_with_time(dt, [optional scheduler])
        2 - res = source.take_until_with_time(5000, [optional scheduler])

        Keyword Arguments:
        end_time -- {Number | Date} Time to stop taking elements from the source
            sequence. If this value is less than or equal to Date(), the
            result stream will complete immediately.
        scheduler -- {Scheduler} Scheduler to run the timer on.

        Returns an observable {Observable} sequence with the elements taken
        until the specified end time.
        """
self
end_time
examples
None