concurrent.py 459 B

1234567891011121314
  1. """pyzmq does not ship tornado's futures,
  2. this just raises informative NotImplementedErrors to avoid having to change too much code.
  3. """
  4. class NotImplementedFuture(object):
  5. def __init__(self, *args, **kwargs):
  6. raise NotImplementedError("pyzmq does not ship tornado's Futures, "
  7. "install tornado >= 3.0 for future support."
  8. )
  9. Future = TracebackFuture = NotImplementedFuture
  10. def is_future(x):
  11. return isinstance(x, Future)