# flake8: noqa
from .typing import Observer, Scheduler

from .disposable import Disposable
from .anonymousobserver import AnonymousObserver

from . import observerextensions
from .pipe import pipe

from .observable import Observable
from .observable import AnonymousObservable
from .observable import ConnectableObservable
from .observable import GroupedObservable

@@ -350,16 +350,56 @@
 oupedObservable%0A
+%0Afrom .observerbase import ObserverBase%0A

Add missing import