Skip to content

Commit

Permalink
fix: add property is_disposed
Browse files Browse the repository at this point in the history
  • Loading branch information
phi-friday committed Feb 24, 2024
1 parent 59597d9 commit c04e717
Showing 1 changed file with 5 additions and 0 deletions.
5 changes: 5 additions & 0 deletions src/async_wrapper/pipe.py
Original file line number Diff line number Diff line change
Expand Up @@ -101,6 +101,11 @@ def __init__(
self._is_disposed = False
self._dispose_lock = anyio.Lock()

@property
def is_disposed(self) -> bool:
"""is disposed"""
return self._is_disposed

@override
async def next(self, value: InputT) -> OutputT:
if self._is_disposed:
Expand Down

0 comments on commit c04e717

Please sign in to comment.