rx/core/observablebase.py
def replay(self, mapper: Mapper = None, buffer_size: int = None, window: timedelta = None,
               scheduler: Scheduler = None) -> 'Union[ObservableBase, rx.core.ConnectableObservable]':
        """Returns an observable sequence that is the result of invoking
        the mapper on a connectable observable sequence that shares a
        single subscription to the underlying sequence replaying
        notifications subject to a maximum time length for the replay
        buffer.

        Note:
            This operator is a specialization of Multicast using a
            ReplaySubject.

        Example:
            >>> res = source.replay(buffer_size=3)
            >>> res = source.replay(buffer_size=3, window=500)
            >>> res = source.replay(None, 3, 500)
            >>> res = source.replay(lambda x: x.take(6).repeat(), 3, 500)

        Args:
            mapper: Selector function which can use the multicasted
                source sequence as many times as needed, without causing
                multiple subscriptions to the source sequence.
                Subscribers to the given source will receive all the
                notifications of the source subject to the specified
                replay buffer trimming policy.
            buffer_size: Maximum element count of the replay buffer.
            window: Maximum time length of the replay buffer.

        Returns:
            An observable sequence that contains the elements of a
            sequence produced by multicasting the source sequence within
            a mapper function.
        """
        from ..operators.observable.replay import replay
        return replay(self, mapper, buffer_size, window, scheduler)
Returns an observable sequence that is the result of invoking
        the mapper on a connectable observable sequence that shares a
        single subscription to the underlying sequence replaying
        notifications subject to a maximum time length for the replay
        buffer.

        Note:
            This operator is a specialization of Multicast using a
            ReplaySubject.

        Example:
            >>> res = source.replay(buffer_size=3)
            >>> res = source.replay(buffer_size=3, window=500)
            >>> res = source.replay(None, 3, 500)
            >>> res = source.replay(lambda x: x.take(6).repeat(), 3, 500)

        Args:
            mapper: Selector function which can use the multicasted
                source sequence as many times as needed, without causing
                multiple subscriptions to the source sequence.
                Subscribers to the given source will receive all the
                notifications of the source subject to the specified
                replay buffer trimming policy.
            buffer_size: Maximum element count of the replay buffer.
            window: Maximum time length of the replay buffer.

        Returns:
            An observable sequence that contains the elements of a
            sequence produced by multicasting the source sequence within
            a mapper function.
        
Returns an observable sequence that is the result of invoking
the mapper on a connectable observable sequence that shares a
single subscription to the underlying sequence replaying
notifications subject to a maximum time length for the replay
buffer.

This operator is a specialization of Multicast using a
ReplaySubject.
Returns an observable sequence that is the result of invoking the mapper on a connectable observable sequence that shares a single subscription to the underlying sequence replaying notifications subject to a maximum time length for the replay buffer . This operator is a specialization of Multicast using a ReplaySubject .
def replay(self, mapper: Mapper = None, buffer_size: int = None, window: timedelta = None,
               scheduler: Scheduler = None) -> 'Union[ObservableBase, rx.core.ConnectableObservable]':
        from ..operators.observable.replay import replay
        return replay(self, mapper, buffer_size, window, scheduler)
def replay ( self , mapper : Mapper = None , buffer_size : int = None , window : timedelta = None , scheduler : Scheduler = None ) -> 'Union[ObservableBase, rx.core.ConnectableObservable]' : from . . operators . observable . replay import replay return replay ( self , mapper , buffer_size , window , scheduler )
Returns an observable sequence that is the result of invoking
the mapper on a connectable observable sequence that shares a
single subscription to the underlying sequence replaying
notifications subject to a maximum time length for the replay
buffer.
Returns an observable sequence that is the result of invoking the mapper on a connectable observable sequence that shares a single subscription to the underlying sequence replaying notifications subject to a maximum time length for the replay buffer .
"""Returns an observable sequence that is the result of invoking
        the mapper on a connectable observable sequence that shares a
        single subscription to the underlying sequence replaying
        notifications subject to a maximum time length for the replay
        buffer.

        Note:
            This operator is a specialization of Multicast using a
            ReplaySubject.

        Example:
            >>> res = source.replay(buffer_size=3)
            >>> res = source.replay(buffer_size=3, window=500)
            >>> res = source.replay(None, 3, 500)
            >>> res = source.replay(lambda x: x.take(6).repeat(), 3, 500)

        Args:
            mapper: Selector function which can use the multicasted
                source sequence as many times as needed, without causing
                multiple subscriptions to the source sequence.
                Subscribers to the given source will receive all the
                notifications of the source subject to the specified
                replay buffer trimming policy.
            buffer_size: Maximum element count of the replay buffer.
            window: Maximum time length of the replay buffer.

        Returns:
            An observable sequence that contains the elements of a
            sequence produced by multicasting the source sequence within
            a mapper function.
        """
An observable sequence that contains the elements of a
sequence produced by multicasting the source sequence within
a mapper function.
An observable sequence that contains the elements of a sequence produced by multicasting the source sequence within a mapper function .
self
mapper
Mapper
Selector function which can use the multicasted
source sequence as many times as needed, without causing
multiple subscriptions to the source sequence.
Subscribers to the given source will receive all the
notifications of the source subject to the specified
replay buffer trimming policy.
Selector function which can use the multicasted source sequence as many times as needed without causing multiple subscriptions to the source sequence . Subscribers to the given source will receive all the notifications of the source subject to the specified replay buffer trimming policy .
buffer_size
int
Maximum element count of the replay buffer.
Maximum element count of the replay buffer .
window
timedelta
Maximum time length of the replay buffer.
Maximum time length of the replay buffer .
scheduler
Scheduler
examples
None