from .observable import Observable
from .anonymousobservable import AnonymousObservable
from .observer import Observer
from . import checkedobserver
from . import linq
from . import backpressure

try:
    from asyncio import Future
except ImportError:
    Future = None

# Rx configuration dictionary
config = {
    "Future" : Future
}
from threading import Lock

from .observable import Observable
from .anonymousobservable import AnonymousObservable
from .observer import Observer
from . import checkedobserver
from . import linq
from . import backpressure

try:
    from asyncio import Future
except ImportError:
    Future = None

# Rx configuration dictionary
config = {
    "Future" : Future,
    "Lock" : Lock
}
Make it possible to set custom Lock
Make it possible to set custom Lock
