rx/core/observablebase.py
def multicast(self, subject=None, subject_factory=None, mapper=None) -> 'ObservableBase':
        """Multicasts the source sequence notifications through an instantiated
        subject into all uses of the sequence within a mapper function. Each
        subscription to the resulting sequence causes a separate multicast
        invocation, exposing the sequence resulting from the mapper function's
        invocation. For specializations with fixed subject types, see Publish,
        PublishLast, and Replay.

        Example:
        1 - res = source.multicast(observable)
        2 - res = source.multicast(subject_factory=lambda scheduler: Subject(),
                                mapper=lambda x: x)

        Keyword arguments:
        subject_factory -- {Function} Factory function to create an
            intermediate subject through which the source sequence's elements
            will be multicast to the mapper function.
        subject -- Subject {Subject} to push source elements into.
        mapper -- {Function} [Optional] Optional mapper function which can
            use the multicasted source sequence subject to the policies enforced
            by the created subject. Specified only if subject_factory" is a
            factory function.

        Returns an observable {Observable} sequence that contains the elements
        of a sequence produced by multicasting the source sequence within a
        mapper function.
        """
        from ..operators.observable.multicast import multicast
        return multicast(self, subject, subject_factory, mapper)
Multicasts the source sequence notifications through an instantiated
        subject into all uses of the sequence within a mapper function. Each
        subscription to the resulting sequence causes a separate multicast
        invocation, exposing the sequence resulting from the mapper function's
        invocation. For specializations with fixed subject types, see Publish,
        PublishLast, and Replay.

        Example:
        1 - res = source.multicast(observable)
        2 - res = source.multicast(subject_factory=lambda scheduler: Subject(),
                                mapper=lambda x: x)

        Keyword arguments:
        subject_factory -- {Function} Factory function to create an
            intermediate subject through which the source sequence's elements
            will be multicast to the mapper function.
        subject -- Subject {Subject} to push source elements into.
        mapper -- {Function} [Optional] Optional mapper function which can
            use the multicasted source sequence subject to the policies enforced
            by the created subject. Specified only if subject_factory" is a
            factory function.

        Returns an observable {Observable} sequence that contains the elements
        of a sequence produced by multicasting the source sequence within a
        mapper function.
        
Multicasts the source sequence notifications through an instantiated
subject into all uses of the sequence within a mapper function. Each
subscription to the resulting sequence causes a separate multicast
invocation, exposing the sequence resulting from the mapper function's
invocation. For specializations with fixed subject types, see Publish,
PublishLast, and Replay.
Multicasts the source sequence notifications through an instantiated subject into all uses of the sequence within a mapper function . Each subscription to the resulting sequence causes a separate multicast invocation exposing the sequence resulting from the mapper function ' s invocation . For specializations with fixed subject types see Publish PublishLast and Replay .
def multicast(self, subject=None, subject_factory=None, mapper=None) -> 'ObservableBase':
        from ..operators.observable.multicast import multicast
        return multicast(self, subject, subject_factory, mapper)
def multicast ( self , subject = None , subject_factory = None , mapper = None ) -> 'ObservableBase' : from . . operators . observable . multicast import multicast return multicast ( self , subject , subject_factory , mapper )
Multicasts the source sequence notifications through an instantiated
subject into all uses of the sequence within a mapper function.
Multicasts the source sequence notifications through an instantiated subject into all uses of the sequence within a mapper function .
"""Multicasts the source sequence notifications through an instantiated
        subject into all uses of the sequence within a mapper function. Each
        subscription to the resulting sequence causes a separate multicast
        invocation, exposing the sequence resulting from the mapper function's
        invocation. For specializations with fixed subject types, see Publish,
        PublishLast, and Replay.

        Example:
        1 - res = source.multicast(observable)
        2 - res = source.multicast(subject_factory=lambda scheduler: Subject(),
                                mapper=lambda x: x)

        Keyword arguments:
        subject_factory -- {Function} Factory function to create an
            intermediate subject through which the source sequence's elements
            will be multicast to the mapper function.
        subject -- Subject {Subject} to push source elements into.
        mapper -- {Function} [Optional] Optional mapper function which can
            use the multicasted source sequence subject to the policies enforced
            by the created subject. Specified only if subject_factory" is a
            factory function.

        Returns an observable {Observable} sequence that contains the elements
        of a sequence produced by multicasting the source sequence within a
        mapper function.
        """
self
subject
subject_factory
mapper
examples
None