from rx import config
from rx.core import Disposable


class BooleanDisposable(Disposable):
    """Represents a Disposable that can be checked for status."""

    def __init__(self):
        """Initializes a new instance of the BooleanDisposable class."""

        self.is_disposed = False
        self.lock = config["concurrency"].RLock()

        super(BooleanDisposable, self).__init__()

    def dispose(self):
        """Sets the status to disposed"""

        self.is_disposed = True