# Stubs for rx.subjects.asyncsubject (Python 3)
#
# NOTE: This dynamically typed stub was automatically generated by stubgen.

from .innersubscription import InnerSubscription
from rx.core import ObservableBase, Observer
from typing import Any

class AsyncSubject(ObservableBase, Observer):
    is_disposed: bool = ...
    is_stopped: bool = ...
    value: Any = ...
    has_value: bool = ...
    observers: Any = ...
    exception: Any = ...
    lock: Any = ...
    def __init__(self) -> None: ...
    def check_disposed(self) -> None: ...
    def on_completed(self) -> None: ...
    def on_error(self, exception: Any) -> None: ...
    def on_next(self, value: Any) -> None: ...
    def dispose(self) -> None: ...