rx/core/observablebase.py
def throttle_first(self, window_duration: Union[timedelta, int]) -> 'ObservableBase':
        """Returns an Observable that emits only the first item emitted
        by the source Observable during sequential time windows of a
        specified duration.

        Keyword arguments:
        window_duration -- time to wait before emitting another item
            after emitting the last item.
        Returns an Observable that performs the throttle operation.
        """

        from ..operators.observable.throttlefirst import throttle_first
        return throttle_first(self, window_duration)
Returns an Observable that emits only the first item emitted
        by the source Observable during sequential time windows of a
        specified duration.

        Keyword arguments:
        window_duration -- time to wait before emitting another item
            after emitting the last item.
        Returns an Observable that performs the throttle operation.
        
Returns an Observable that emits only the first item emitted
by the source Observable during sequential time windows of a
specified duration.

Keyword arguments:
window_duration -- time to wait before emitting another item
after emitting the last item.
Returns an Observable that performs the throttle operation.
Returns an Observable that emits only the first item emitted by the source Observable during sequential time windows of a specified duration . Keyword arguments : window_duration -- time to wait before emitting another item after emitting the last item . Returns an Observable that performs the throttle operation .
def throttle_first(self, window_duration: Union[timedelta, int]) -> 'ObservableBase':
        from ..operators.observable.throttlefirst import throttle_first
        return throttle_first(self, window_duration)
def throttle_first ( self , window_duration : Union [ timedelta , int ] ) -> 'ObservableBase' : from . . operators . observable . throttlefirst import throttle_first return throttle_first ( self , window_duration )
Returns an Observable that emits only the first item emitted
by the source Observable during sequential time windows of a
specified duration.
Returns an Observable that emits only the first item emitted by the source Observable during sequential time windows of a specified duration .
"""Returns an Observable that emits only the first item emitted
        by the source Observable during sequential time windows of a
        specified duration.

        Keyword arguments:
        window_duration -- time to wait before emitting another item
            after emitting the last item.
        Returns an Observable that performs the throttle operation.
        """
self
window_duration
Union[timedelta, int]