Cannot run filter example about aioreactive HOT 2 CLOSED

from typing import Callable

from aioreactive.core import AsyncObservable
from functools import wraps, partial
import importlib
import sys
import aioreactive.operators
def pipe(source: AsyncObservable, *args: Callable[[AsyncObservable], AsyncObservable]) -> AsyncObservable:
    for op in args:
        source = op(source)
    return source

_this_module = sys.modules[__name__]

def setup(x):
    def fn(*args, **kwargs):
        ff = eval(f"aioreactive.operators.{x}")
        return partial(ff, *args, **kwargs)
    setattr(_this_module, x , fn)

for x in ["concat", "debounce", "delay", "filter", "map", ]:
    setup(x)

from aioreactive.core import Operators as op