rx/core/observable.py
def generate(initial_state, condition, iterate, result_mapper) -> ObservableBase:
        """Generates an observable sequence by running a state-driven
        loop producing the sequence's elements, using the specified
        scheduler to send out observer messages.

        1 - res = rx.Observable.generate(0,
            lambda x: x < 10,
            lambda x: x + 1,
            lambda x: x)

        Keyword arguments:
        initial_state -- Initial state.
        condition -- Condition to terminate generation (upon returning
            False).
        iterate -- Iteration step function.
        result_mapper -- Selector function for results produced in the
            sequence.

        Returns the generated sequence.
        """
        from ..operators.observable.generate import generate
        return generate(initial_state, condition, iterate, result_mapper)
Generates an observable sequence by running a state-driven
        loop producing the sequence's elements, using the specified
        scheduler to send out observer messages.

        1 - res = rx.Observable.generate(0,
            lambda x: x < 10,
            lambda x: x + 1,
            lambda x: x)

        Keyword arguments:
        initial_state -- Initial state.
        condition -- Condition to terminate generation (upon returning
            False).
        iterate -- Iteration step function.
        result_mapper -- Selector function for results produced in the
            sequence.

        Returns the generated sequence.
        
Generates an observable sequence by running a state-driven
loop producing the sequence's elements, using the specified
scheduler to send out observer messages.



Keyword arguments:
initial_state -- Initial state.
condition -- Condition to terminate generation (upon returning
False).
iterate -- Iteration step function.
result_mapper -- Selector function for results produced in the
sequence.

Returns the generated sequence.
Generates an observable sequence by running a state - driven loop producing the sequence ' s elements using the specified scheduler to send out observer messages . Keyword arguments : initial_state -- Initial state . condition -- Condition to terminate generation ( upon returning False ) . iterate -- Iteration step function . result_mapper -- Selector function for results produced in the sequence . Returns the generated sequence .
def generate(initial_state, condition, iterate, result_mapper) -> ObservableBase:
        from ..operators.observable.generate import generate
        return generate(initial_state, condition, iterate, result_mapper)
def generate ( initial_state , condition , iterate , result_mapper ) -> ObservableBase : from . . operators . observable . generate import generate return generate ( initial_state , condition , iterate , result_mapper )
Generates an observable sequence by running a state-driven
loop producing the sequence's elements, using the specified
scheduler to send out observer messages.
Generates an observable sequence by running a state - driven loop producing the sequence ' s elements using the specified scheduler to send out observer messages .
"""Generates an observable sequence by running a state-driven
        loop producing the sequence's elements, using the specified
        scheduler to send out observer messages.

        1 - res = rx.Observable.generate(0,
            lambda x: x < 10,
            lambda x: x + 1,
            lambda x: x)

        Keyword arguments:
        initial_state -- Initial state.
        condition -- Condition to terminate generation (upon returning
            False).
        iterate -- Iteration step function.
        result_mapper -- Selector function for results produced in the
            sequence.

        Returns the generated sequence.
        """
initial_state
condition
iterate
result_mapper