Source code for stdlibx.streams.utils

 1from __future__ import annotations
 2
 3from typing import TypeVar
 4
 5from stdlibx.streams._subject import Subject
 6from stdlibx.streams._types import Observable
 7
 8T = TypeVar("T")
 9
10

[docs]
11def as_observable(value: Observable[T] | T) -> Observable[T]:
12    if isinstance(value, Observable):
13        return value
14    return Subject(value)