async_rx.observable.rx_of

Complexity

Total Complexity

1

Size/Duplication

Total Lines	18
Duplicated Lines	0 %

Importance

Changes

0

1 Function

Rating	Name	Duplication	Size	Complexity
A	rx_of()	0	11	1

from ..protocol import Observable
from .rx_from import rx_from

__all__ = ["rx_of"]


def rx_of(*args) -> Observable:
    """Convert arguments into an observable sequence.

    Args:
        args: any list of argument to send to observer.

    Returns:
        (Observable): observable instance.

    """
    return rx_from(observable_input=args)