Search code, repositories, users, issues, pull requests...

await waiter

await self._async_create_endpoints()

transport, protocol = await loop.create_datagram_endpoint( # type: ignore[type-var]

transport.close()

self._loop.call_soon(self._call_connection_lost, None)

self._check_closed()

raise RuntimeError('Event loop is closed')

await waiter

await self._async_create_endpoints()

transport, protocol = await loop.create_datagram_endpoint( # type: ignore[type-var]

transport.close()

self._loop.call_soon(self._call_connection_lost, None)

self._check_closed()

raise RuntimeError('Event loop is closed')

await waiter

await self._async_create_endpoints()

transport, protocol = await loop.create_datagram_endpoint( # type: ignore[type-var]

transport.close()

self._loop.call_soon(self._call_connection_lost, None)

self._check_closed()

raise RuntimeError('Event loop is closed')

await waiter

await self._async_create_endpoints()

transport, protocol = await loop.create_datagram_endpoint( # type: ignore[type-var]

transport.close()

self._loop.call_soon(self._call_connection_lost, None)

self._check_closed()

raise RuntimeError('Event loop is closed')

await waiter

await self._async_create_endpoints()

transport, protocol = await loop.create_datagram_endpoint( # type: ignore[type-var]

transport.close()

self._loop.call_soon(self._call_connection_lost, None)

self._check_closed()

raise RuntimeError('Event loop is closed')

await waiter

await self._async_create_endpoints()

transport, protocol = await loop.create_datagram_endpoint( # type: ignore[type-var]

transport.close()

self._loop.call_soon(self._call_connection_lost, None)

self._check_closed()

raise RuntimeError('Event loop is closed')

await waiter

await self._async_create_endpoints()

transport, protocol = await loop.create_datagram_endpoint( # type: ignore[type-var]

transport.close()

self._loop.call_soon(self._call_connection_lost, None)

self._check_closed()

raise RuntimeError('Event loop is closed')

await waiter

await self._async_create_endpoints()

transport, protocol = await loop.create_datagram_endpoint( # type: ignore[type-var]

transport.close()

self._loop.call_soon(self._call_connection_lost, None)

self._check_closed()

raise RuntimeError('Event loop is closed')

await waiter

await self._async_create_endpoints()

transport, protocol = await loop.create_datagram_endpoint( # type: ignore[type-var]

transport.close()

self._loop.call_soon(self._call_connection_lost, None)

self._check_closed()

raise RuntimeError('Event loop is closed')

await waiter

await self._async_create_endpoints()

transport, protocol = await loop.create_datagram_endpoint( # type: ignore[type-var]

transport.close()

self._loop.call_soon(self._call_connection_lost, None)

self._check_closed()

raise RuntimeError('Event loop is closed')

await waiter

await self._async_create_endpoints()

transport, protocol = await loop.create_datagram_endpoint( # type: ignore[type-var]

transport.close()

self._loop.call_soon(self._call_connection_lost, None)

self._check_closed()

raise RuntimeError('Event loop is closed')

await waiter

await self._async_create_endpoints()

transport, protocol = await loop.create_datagram_endpoint( # type: ignore[type-var]

transport.close()

self._loop.call_soon(self._call_connection_lost, None)

self._check_closed()

raise RuntimeError('Event loop is closed')

await waiter

await self._async_create_endpoints()

transport, protocol = await loop.create_datagram_endpoint( # type: ignore[type-var]

transport.close()

self._loop.call_soon(self._call_connection_lost, None)

self._check_closed()