rx/core/observablebase.py
def publish_value(self, initial_value: Any, mapper: Mapper = None) -> 'ObservableBase':
        """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 and starts with initial_value.

        This operator is a specialization of Multicast using a BehaviorSubject.

        Example:
        res = source.publish_value(42)
        res = source.publish_value(42, lambda x: x.map(lambda y: y * y))

        Keyword arguments:
        initial_value -- Initial value received by observers upon
            subscription.
        mapper -- [Optional] Optional mapper 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 immediately receive the initial
            value, followed by all notifications of the source from the time of
            the subscription on.

        Returns an observable sequence that contains the elements of a
        sequence produced by multicasting the source sequence within a
        mapper function.
        """
        from ..operators.observable.publishvalue import publish_value
        return publish_value(self, initial_value, mapper)
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 and starts with initial_value.

        This operator is a specialization of Multicast using a BehaviorSubject.

        Example:
        res = source.publish_value(42)
        res = source.publish_value(42, lambda x: x.map(lambda y: y * y))

        Keyword arguments:
        initial_value -- Initial value received by observers upon
            subscription.
        mapper -- [Optional] Optional mapper 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 immediately receive the initial
            value, followed by all notifications of the source from the time of
            the subscription on.

        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 and starts with initial_value.

This operator is a specialization of Multicast using a BehaviorSubject.
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 and starts with initial_value . This operator is a specialization of Multicast using a BehaviorSubject .
def publish_value(self, initial_value: Any, mapper: Mapper = None) -> 'ObservableBase':
        from ..operators.observable.publishvalue import publish_value
        return publish_value(self, initial_value, mapper)
def publish_value ( self , initial_value : Any , mapper : Mapper = None ) -> 'ObservableBase' : from . . operators . observable . publishvalue import publish_value return publish_value ( self , initial_value , mapper )
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 and starts with initial_value.
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 and starts with initial_value .
"""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 and starts with initial_value.

        This operator is a specialization of Multicast using a BehaviorSubject.

        Example:
        res = source.publish_value(42)
        res = source.publish_value(42, lambda x: x.map(lambda y: y * y))

        Keyword arguments:
        initial_value -- Initial value received by observers upon
            subscription.
        mapper -- [Optional] Optional mapper 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 immediately receive the initial
            value, followed by all notifications of the source from the time of
            the subscription on.

        Returns an observable sequence that contains the elements of a
        sequence produced by multicasting the source sequence within a
        mapper function.
        """
self
initial_value
Any
mapper
Mapper
examples
None