Source code for async_rx.observable.rx_of

from ..protocol import Observable
from .rx_from import rx_from

__all__ = ["rx_of"]


[docs]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)