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

+ 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
+     "Future" : Future,
+     "Lock" : Lock
  }
Make it possible to set custom Lock
## Code Before:
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
}
## Instruction:
Make it possible to set custom Lock
## Code After:
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
}