Source code for rx.core.py3.observable

from abc import ABCMeta, abstractmethod


class Observable(metaclass=ABCMeta):
    @abstractmethod
    def subscribe(self, observer):
        return NotImplemented