Source code for reactivestreams.subscription

from abc import ABCMeta, abstractmethod




class Subscription(metaclass=ABCMeta):
    """
    Backpressure stream control.
    """

    @abstractmethod
    def request(self, n: int):
        ...

    @abstractmethod
    def cancel(self):
        ...



class DefaultSubscription(Subscription):
    def request(self, n: int):
        pass

    def cancel(self):
        pass