async def METHOD_NAME(
    self,
    headers: Optional[Dict[str, str]] = None,
    subprotocol: Optional[str] = None
):
    if self._proto.transport:
        return
    await self._proto.init()
    self.receive = self._wrapped_receive
    self.send = self._wrapped_send