async def _incoming_from_rtm(<EOL>self, url: str, bot_id: str<EOL>) -> AsyncIterator[events.Event]:
async for data in self._rtm(url):<EOL><INDENT>event = events.Event.from_rtm(json.loads(data))<EOL>if sansio.need_reconnect(event):<EOL><INDENT>break<EOL><DEDENT>elif sansio.discard_event(event, bot_id):<EOL><INDENT>continue<EOL><DEDENT>else:<EOL><INDENT>yield event<EOL><DEDENT><DEDENT>
Connect and discard incoming RTM event if necessary.

:param url: Websocket url
:param bot_id: Bot ID
:return: Incoming events