(self, scope: Scope, receive: Receive)
| 26 | """ |
| 27 | |
| 28 | def __init__(self, scope: Scope, receive: Receive): |
| 29 | super().__init__(scope, receive) |
| 30 | self._wrapped_rcv_disconnected = False |
| 31 | self._wrapped_rcv_consumed = False |
| 32 | self._wrapped_rc_stream = self.stream() |
| 33 | |
| 34 | async def wrapped_receive(self) -> Message: |
| 35 | # wrapped_rcv state 1: disconnected |