byp4a55 professor6T9

Linux das102.truehost.cloud 4.18.0-553.8.1.lve.el8.x86_64 #1 SMP Thu Jul 4 16:24:39 UTC 2024 x86_64
LiteSpeed
156.232.88.2

File Name : returnvalue.py

from typing import Any, Callable, Optional, TypeVar

from reactivex import Observable, abc
from reactivex.scheduler import CurrentThreadScheduler

_T = TypeVar("_T")

def return_value_(
    value: _T, scheduler: Optional[abc.SchedulerBase] = None
) -> Observable[_T]:
    """Returns an observable sequence that contains a single element,
    using the specified scheduler to send out observer messages.
    There is an alias called 'just'.

Examples:
        >>> res = return(42)
        >>> res = return(42, rx.Scheduler.timeout)

Args:
        value: Single element in the resulting observable sequence.

Returns:
        An observable sequence containing the single specified
        element.
    """

def subscribe(
        observer: abc.ObserverBase[_T], scheduler_: Optional[abc.SchedulerBase] = None
    ) -> abc.DisposableBase:
        _scheduler = scheduler or scheduler_ or CurrentThreadScheduler.singleton()

def action(scheduler: abc.SchedulerBase, state: Any = None) -> None:
            observer.on_next(value)
            observer.on_completed()

return _scheduler.schedule(action)

return Observable(subscribe)

def from_callable_(
    supplier: Callable[[], _T], scheduler: Optional[abc.SchedulerBase] = None
) -> Observable[_T]:
    def subscribe(
        observer: abc.ObserverBase[_T], scheduler_: Optional[abc.SchedulerBase] = None
    ) -> abc.DisposableBase:
        _scheduler = scheduler or scheduler_ or CurrentThreadScheduler.singleton()

def action(_: abc.SchedulerBase, __: Any = None) -> None:
            nonlocal observer

try:
                observer.on_next(supplier())
                observer.on_completed()
            except Exception as e:  # pylint: disable=broad-except
                observer.on_error(e)

return _scheduler.schedule(action)

return Observable(subscribe)

__all__ = ["return_value_", "from_callable_"]

Name	Type	Size	Owner/Group	Permission	Last Modified	Actions
.	dir	-	root/root	0755	2026-02-16 08:57:59
..	dir	-	root/root	0755	2026-02-16 08:57:59
__pycache__	dir	-	root/root	0755	2026-02-16 08:57:59
__init__.py	text/x-script.python	213 B	root/root	0644	2026-02-16 08:57:59
amb.py	text/x-script.python	677 B	root/root	0644	2026-02-16 08:57:59
case.py	text/x-script.python	893 B	root/root	0644	2026-02-16 08:57:59
catch.py	text/x-script.python	2.51 KB	root/root	0644	2026-02-16 08:57:59
combinelatest.py	text/x-script.python	2.17 KB	root/root	0644	2026-02-16 08:57:59
concat.py	text/x-script.python	1.84 KB	root/root	0644	2026-02-16 08:57:59
connectableobservable.py	text/x-script.python	2.69 KB	root/root	0644	2026-02-16 08:57:59
defer.py	text/x-script.python	1.38 KB	root/root	0644	2026-02-16 08:57:59
empty.py	text/x-script.python	616 B	root/root	0644	2026-02-16 08:57:59
forkjoin.py	text/x-script.python	2.14 KB	root/root	0644	2026-02-16 08:57:59
fromcallback.py	text/x-script.python	1.83 KB	root/root	0644	2026-02-16 08:57:59
fromfuture.py	text/x-script.python	1.37 KB	root/root	0644	2026-02-16 08:57:59
fromiterable.py	text/x-script.python	1.61 KB	root/root	0644	2026-02-16 08:57:59
generate.py	text/x-script.python	1.61 KB	root/root	0644	2026-02-16 08:57:59
generatewithrelativetime.py	text/x-script.python	2.65 KB	root/root	0644	2026-02-16 08:57:59
groupedobservable.py	text/x-script.python	1.27 KB	root/root	0644	2026-02-16 08:57:59
ifthen.py	text/x-script.python	1.63 KB	root/root	0644	2026-02-16 08:57:59
interval.py	text/x-script.python	271 B	root/root	0644	2026-02-16 08:57:59
marbles.py	text/x-script.python	9.04 KB	root/root	0644	2026-02-16 08:57:59
merge.py	text/x-script.python	284 B	root/root	0644	2026-02-16 08:57:59
never.py	text/x-script.python	605 B	root/root	0644	2026-02-16 08:57:59
observable.py	text/x-script.python	11.21 KB	root/root	0644	2026-02-16 08:57:59
onerrorresumenext.py	text/x-script.python	2.17 KB	root/root	0644	2026-02-16 08:57:59
range.py	text/x-script.python	2.1 KB	root/root	0644	2026-02-16 08:57:59
repeat.py	text/x-script.python	890 B	root/root	0644	2026-02-16 08:57:59
returnvalue.py	text/x-script.python	1.89 KB	root/root	0644	2026-02-16 08:57:59
start.py	text/x-script.python	1.07 KB	root/root	0644	2026-02-16 08:57:59
startasync.py	text/x-script.python	409 B	root/root	0644	2026-02-16 08:57:59
throw.py	text/x-script.python	754 B	root/root	0644	2026-02-16 08:57:59
timer.py	text/x-script.python	4.39 KB	root/root	0644	2026-02-16 08:57:59
toasync.py	text/x-script.python	1.65 KB	root/root	0644	2026-02-16 08:57:59
using.py	text/x-script.python	1.65 KB	root/root	0644	2026-02-16 08:57:59
withlatestfrom.py	text/x-script.python	1.94 KB	root/root	0644	2026-02-16 08:57:59
zip.py	text/x-script.python	2.76 KB	root/root	0644	2026-02-16 08:57:59

Team Anon Force

https://t.me/Professor6T9x