# Path: rx/disposable.py
# class Disposable(object):
#   """Represents a disposable object"""
# 
#   def dispose(self):
#     pass
# 
#   def __enter__(self):
#     return self
# 
#   def __exit__(self, exc_type, exc_value, traceback):
#     self.dispose()
# 
#   @staticmethod
#   def create(action):
#     return AnonymouseDisposable(action)
# 
#   @staticmethod
#   def empty():
#     return disposableEmpty
# 
# Path: rx/observable.py
# class Observable(object):
#   """Provides all extension methods to Observable"""
# 
#   def subscribe(self, observerOrOnNext=noop, onError=noop, onComplete=noop):
#     observer = observerOrOnNext
# 
#     if observerOrOnNext == None or callable(observerOrOnNext):
#       observer = Observer.create(observerOrOnNext, onError, onComplete)
# 
#     return self.subscribeCore(observer)
# 
#   def subscribeCore(self, observer):
#     raise NotImplementedError()
# 
#   def subscribeSafe(self, observer):
#     if isinstance(self, ObservableBase):
#       return self.subscribeCore(observer)
#     elif isinstance(self, Producer):
#       return self.subscribeRaw(observer, False)
# 
#     d = Disposable.empty()
# 
#     try:
#       d = self.subscribeCore(observer)
#     except Exception as e:
#       observer.onError(e)
# 
#     return d


from rx.disposable import Disposable
from rx.observable import Observable


class Never(Observable):
  def __init__(self):
    super(Never, self).__init__()


# Path: rx/disposable.py
# class Disposable(object):
#   """Represents a disposable object"""
# 
#   def dispose(self):
#     pass
# 
#   def __enter__(self):
#     return self
# 
#   def __exit__(self, exc_type, exc_value, traceback):
#     self.dispose()
# 
#   @staticmethod
#   def create(action):
#     return AnonymouseDisposable(action)
# 
#   @staticmethod
#   def empty():
#     return disposableEmpty
# 
# Path: rx/observable.py
# class Observable(object):
#   """Provides all extension methods to Observable"""
# 
#   def subscribe(self, observerOrOnNext=noop, onError=noop, onComplete=noop):
#     observer = observerOrOnNext
# 
#     if observerOrOnNext == None or callable(observerOrOnNext):
#       observer = Observer.create(observerOrOnNext, onError, onComplete)
# 
#     return self.subscribeCore(observer)
# 
#   def subscribeCore(self, observer):
#     raise NotImplementedError()
# 
#   def subscribeSafe(self, observer):
#     if isinstance(self, ObservableBase):
#       return self.subscribeCore(observer)
#     elif isinstance(self, Producer):
#       return self.subscribeRaw(observer, False)
# 
#     d = Disposable.empty()
# 
#     try:
#       d = self.subscribeCore(observer)
#     except Exception as e:
#       observer.onError(e)
# 
#     return d


# Path: rx/linq/never.py
from rx.disposable import Disposable
from rx.observable import Observable



class Never(Observable):
  def __init__(self):
    super(Never, self).__init__()


  def subscribeCore(self, observer):