"""
drain.exceptions.py
~~~~~~~~~~~~~~~~~~~

Contains custom errors definitions
"""


class DrainError(Exception):
    """Generic base error """

    ...


class NoObservableSourceError(DrainError):
    """Starting consuming a stream without having set an observable first"""

    ...


class DropRecordError(Exception):
    """A record does not satisfy a given predicate and has to be dropped"""

    ...

7d888bc3631f93c7eceb0b22a51ca99987c3553b
<mask token>


class NoObservableSourceError(DrainError):
    <mask token>
    ...


class DropRecordError(Exception):
    """A record does not satisfy a given predicate and has to be dropped"""
    ...

<mask token>


class NoObservableSourceError(DrainError):
    """Starting consuming a stream without having set an observable first"""
    ...


class DropRecordError(Exception):
    """A record does not satisfy a given predicate and has to be dropped"""
    ...

<mask token>


class DrainError(Exception):
    <mask token>
    ...


class NoObservableSourceError(DrainError):
    """Starting consuming a stream without having set an observable first"""
    ...


class DropRecordError(Exception):
    """A record does not satisfy a given predicate and has to be dropped"""
    ...

<mask token>


class DrainError(Exception):
    """Generic base error """
    ...


class NoObservableSourceError(DrainError):
    """Starting consuming a stream without having set an observable first"""
    ...


class DropRecordError(Exception):
    """A record does not satisfy a given predicate and has to be dropped"""
    ...

"""
drain.exceptions.py
~~~~~~~~~~~~~~~~~~~

Contains custom errors definitions
"""


class DrainError(Exception):
    """Generic base error """

    ...


class NoObservableSourceError(DrainError):
    """Starting consuming a stream without having set an observable first"""

    ...


class DropRecordError(Exception):
    """A record does not satisfy a given predicate and has to be dropped"""

    ...
