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 : _map.py

from typing import Callable, Optional, TypeVar, cast

from reactivex import Observable, abc, compose
from reactivex import operators as ops
from reactivex import typing
from reactivex.internal.basic import identity
from reactivex.internal.utils import infinite
from reactivex.typing import Mapper, MapperIndexed

_T1 = TypeVar("_T1")
_T2 = TypeVar("_T2")

def map_(
    mapper: Optional[Mapper[_T1, _T2]] = None,
) -> Callable[[Observable[_T1]], Observable[_T2]]:
    _mapper = mapper or cast(Mapper[_T1, _T2], identity)

def map(source: Observable[_T1]) -> Observable[_T2]:
        """Partially applied map operator.

Project each element of an observable sequence into a new form
        by incorporating the element's index.

Example:
            >>> map(source)

Args:
            source: The observable source to transform.

Returns:
            Returns an observable sequence whose elements are the
            result of invoking the transform function on each element
            of the source.
        """

def subscribe(
            obv: abc.ObserverBase[_T2], scheduler: Optional[abc.SchedulerBase] = None
        ) -> abc.DisposableBase:
            def on_next(value: _T1) -> None:
                try:
                    result = _mapper(value)
                except Exception as err:  # pylint: disable=broad-except
                    obv.on_error(err)
                else:
                    obv.on_next(result)

return source.subscribe(
                on_next, obv.on_error, obv.on_completed, scheduler=scheduler
            )

return Observable(subscribe)

return map

def map_indexed_(
    mapper_indexed: Optional[MapperIndexed[_T1, _T2]] = None,
) -> Callable[[Observable[_T1]], Observable[_T2]]:
    def _identity(value: _T1, _: int) -> _T2:
        return cast(_T2, value)

_mapper_indexed = mapper_indexed or cast(typing.MapperIndexed[_T1, _T2], _identity)

return compose(
        ops.zip_with_iterable(infinite()),
        ops.starmap_indexed(_mapper_indexed),  # type: ignore
    )

__all__ = ["map_", "map_indexed_"]

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
connectable	dir	-	root/root	0755	2026-02-16 08:57:59
__init__.py	text/x-script.python	129.35 KB	root/root	0644	2026-02-16 08:57:59
_all.py	text/x-script.python	497 B	root/root	0644	2026-02-16 08:57:59
_amb.py	text/x-script.python	3 KB	root/root	0644	2026-02-16 08:57:59
_asobservable.py	text/x-script.python	821 B	root/root	0644	2026-02-16 08:57:59
_average.py	text/x-script.python	1.65 KB	root/root	0644	2026-02-16 08:57:59
_buffer.py	text/x-script.python	2.15 KB	root/root	0644	2026-02-16 08:57:59
_bufferwithtime.py	text/x-script.python	619 B	root/root	0644	2026-02-16 08:57:59
_bufferwithtimeorcount.py	text/x-script.python	557 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	798 B	root/root	0644	2026-02-16 08:57:59
_concat.py	text/x-script.python	695 B	root/root	0644	2026-02-16 08:57:59
_contains.py	text/x-script.python	581 B	root/root	0644	2026-02-16 08:57:59
_count.py	text/x-script.python	558 B	root/root	0644	2026-02-16 08:57:59
_debounce.py	text/x-script.python	5.43 KB	root/root	0644	2026-02-16 08:57:59
_defaultifempty.py	text/x-script.python	1.42 KB	root/root	0644	2026-02-16 08:57:59
_delay.py	text/x-script.python	4.61 KB	root/root	0644	2026-02-16 08:57:59
_delaysubscription.py	text/x-script.python	994 B	root/root	0644	2026-02-16 08:57:59
_delaywithmapper.py	text/x-script.python	3.43 KB	root/root	0644	2026-02-16 08:57:59
_dematerialize.py	text/x-script.python	1.07 KB	root/root	0644	2026-02-16 08:57:59
_distinct.py	text/x-script.python	2.46 KB	root/root	0644	2026-02-16 08:57:59
_distinctuntilchanged.py	text/x-script.python	2.8 KB	root/root	0644	2026-02-16 08:57:59
_do.py	text/x-script.python	10.54 KB	root/root	0644	2026-02-16 08:57:59
_dowhile.py	text/x-script.python	817 B	root/root	0644	2026-02-16 08:57:59
_elementatordefault.py	text/x-script.python	1.51 KB	root/root	0644	2026-02-16 08:57:59
_exclusive.py	text/x-script.python	2.42 KB	root/root	0644	2026-02-16 08:57:59
_expand.py	text/x-script.python	3.01 KB	root/root	0644	2026-02-16 08:57:59
_filter.py	text/x-script.python	2.74 KB	root/root	0644	2026-02-16 08:57:59
_finallyaction.py	text/x-script.python	1.27 KB	root/root	0644	2026-02-16 08:57:59
_find.py	text/x-script.python	1.4 KB	root/root	0644	2026-02-16 08:57:59
_first.py	text/x-script.python	1.15 KB	root/root	0644	2026-02-16 08:57:59
_firstordefault.py	text/x-script.python	2.5 KB	root/root	0644	2026-02-16 08:57:59
_flatmap.py	text/x-script.python	4.18 KB	root/root	0644	2026-02-16 08:57:59
_forkjoin.py	text/x-script.python	843 B	root/root	0644	2026-02-16 08:57:59
_groupby.py	text/x-script.python	852 B	root/root	0644	2026-02-16 08:57:59
_groupbyuntil.py	text/x-script.python	6.16 KB	root/root	0644	2026-02-16 08:57:59
_groupjoin.py	text/x-script.python	5.75 KB	root/root	0644	2026-02-16 08:57:59
_ignoreelements.py	text/x-script.python	929 B	root/root	0644	2026-02-16 08:57:59
_isempty.py	text/x-script.python	534 B	root/root	0644	2026-02-16 08:57:59
_join.py	text/x-script.python	4.48 KB	root/root	0644	2026-02-16 08:57:59
_last.py	text/x-script.python	1.11 KB	root/root	0644	2026-02-16 08:57:59
_lastordefault.py	text/x-script.python	1.92 KB	root/root	0644	2026-02-16 08:57:59
_map.py	text/x-script.python	2.08 KB	root/root	0644	2026-02-16 08:57:59
_materialize.py	text/x-script.python	1.42 KB	root/root	0644	2026-02-16 08:57:59
_max.py	text/x-script.python	995 B	root/root	0644	2026-02-16 08:57:59
_maxby.py	text/x-script.python	1018 B	root/root	0644	2026-02-16 08:57:59
_merge.py	text/x-script.python	5.06 KB	root/root	0644	2026-02-16 08:57:59
_min.py	text/x-script.python	1.15 KB	root/root	0644	2026-02-16 08:57:59
_minby.py	text/x-script.python	2.44 KB	root/root	0644	2026-02-16 08:57:59
_multicast.py	text/x-script.python	2.87 KB	root/root	0644	2026-02-16 08:57:59
_observeon.py	text/x-script.python	1.18 KB	root/root	0644	2026-02-16 08:57:59
_onerrorresumenext.py	text/x-script.python	419 B	root/root	0644	2026-02-16 08:57:59
_pairwise.py	text/x-script.python	1.63 KB	root/root	0644	2026-02-16 08:57:59
_partition.py	text/x-script.python	2.95 KB	root/root	0644	2026-02-16 08:57:59
_pluck.py	text/x-script.python	1.18 KB	root/root	0644	2026-02-16 08:57:59
_publish.py	text/x-script.python	2.19 KB	root/root	0644	2026-02-16 08:57:59
_publishvalue.py	text/x-script.python	901 B	root/root	0644	2026-02-16 08:57:59
_reduce.py	text/x-script.python	1.53 KB	root/root	0644	2026-02-16 08:57:59
_repeat.py	text/x-script.python	1.04 KB	root/root	0644	2026-02-16 08:57:59
_replay.py	text/x-script.python	2.37 KB	root/root	0644	2026-02-16 08:57:59
_retry.py	text/x-script.python	1.06 KB	root/root	0644	2026-02-16 08:57:59
_sample.py	text/x-script.python	2.07 KB	root/root	0644	2026-02-16 08:57:59
_scan.py	text/x-script.python	1.69 KB	root/root	0644	2026-02-16 08:57:59
_sequenceequal.py	text/x-script.python	4.05 KB	root/root	0644	2026-02-16 08:57:59
_single.py	text/x-script.python	1.11 KB	root/root	0644	2026-02-16 08:57:59
_singleordefault.py	text/x-script.python	2.77 KB	root/root	0644	2026-02-16 08:57:59
_skip.py	text/x-script.python	1.3 KB	root/root	0644	2026-02-16 08:57:59
_skiplast.py	text/x-script.python	1.55 KB	root/root	0644	2026-02-16 08:57:59
_skiplastwithtime.py	text/x-script.python	2.3 KB	root/root	0644	2026-02-16 08:57:59
_skipuntil.py	text/x-script.python	2.08 KB	root/root	0644	2026-02-16 08:57:59
_skipuntilwithtime.py	text/x-script.python	2.2 KB	root/root	0644	2026-02-16 08:57:59
_skipwhile.py	text/x-script.python	2.15 KB	root/root	0644	2026-02-16 08:57:59
_skipwithtime.py	text/x-script.python	2.17 KB	root/root	0644	2026-02-16 08:57:59
_slice.py	text/x-script.python	2.26 KB	root/root	0644	2026-02-16 08:57:59
_some.py	text/x-script.python	1.62 KB	root/root	0644	2026-02-16 08:57:59
_startswith.py	text/x-script.python	689 B	root/root	0644	2026-02-16 08:57:59
_subscribeon.py	text/x-script.python	1.7 KB	root/root	0644	2026-02-16 08:57:59
_sum.py	text/x-script.python	511 B	root/root	0644	2026-02-16 08:57:59
_switchlatest.py	text/x-script.python	2.84 KB	root/root	0644	2026-02-16 08:57:59
_take.py	text/x-script.python	1.4 KB	root/root	0644	2026-02-16 08:57:59
_takelast.py	text/x-script.python	1.58 KB	root/root	0644	2026-02-16 08:57:59
_takelastbuffer.py	text/x-script.python	1.66 KB	root/root	0644	2026-02-16 08:57:59
_takelastwithtime.py	text/x-script.python	2.28 KB	root/root	0644	2026-02-16 08:57:59
_takeuntil.py	text/x-script.python	1.48 KB	root/root	0644	2026-02-16 08:57:59
_takeuntilwithtime.py	text/x-script.python	1.67 KB	root/root	0644	2026-02-16 08:57:59
_takewhile.py	text/x-script.python	3.53 KB	root/root	0644	2026-02-16 08:57:59
_takewithtime.py	text/x-script.python	1.81 KB	root/root	0644	2026-02-16 08:57:59
_throttlefirst.py	text/x-script.python	1.84 KB	root/root	0644	2026-02-16 08:57:59
_timeinterval.py	text/x-script.python	1.52 KB	root/root	0644	2026-02-16 08:57:59
_timeout.py	text/x-script.python	3.17 KB	root/root	0644	2026-02-16 08:57:59
_timeoutwithmapper.py	text/x-script.python	4.3 KB	root/root	0644	2026-02-16 08:57:59
_timestamp.py	text/x-script.python	1.32 KB	root/root	0644	2026-02-16 08:57:59
_todict.py	text/x-script.python	1.93 KB	root/root	0644	2026-02-16 08:57:59
_tofuture.py	text/x-script.python	2.01 KB	root/root	0644	2026-02-16 08:57:59
_toiterable.py	text/x-script.python	1.14 KB	root/root	0644	2026-02-16 08:57:59
_tomarbles.py	text/x-script.python	2.26 KB	root/root	0644	2026-02-16 08:57:59
_toset.py	text/x-script.python	996 B	root/root	0644	2026-02-16 08:57:59
_whiledo.py	text/x-script.python	1.05 KB	root/root	0644	2026-02-16 08:57:59
_window.py	text/x-script.python	5.05 KB	root/root	0644	2026-02-16 08:57:59
_windowwithcount.py	text/x-script.python	2.63 KB	root/root	0644	2026-02-16 08:57:59
_windowwithtime.py	text/x-script.python	3.77 KB	root/root	0644	2026-02-16 08:57:59
_windowwithtimeorcount.py	text/x-script.python	3.04 KB	root/root	0644	2026-02-16 08:57:59
_withlatestfrom.py	text/x-script.python	898 B	root/root	0644	2026-02-16 08:57:59
_zip.py	text/x-script.python	2.33 KB	root/root	0644	2026-02-16 08:57:59

Team Anon Force

https://t.me/Professor6T9x