flake8 cleanup

Author: jell-o-fishi

examples/django_channels/django_rsocket/django_rsocket/routing.py

@@ -1,6 +1,7 @@
 from django.urls import path
+
 from .consumers import RSocketConsumer
 
 websocket_urlpatterns = [
     path('rsocket', RSocketConsumer.as_asgi()),
-]
+]

examples/django_channels/server_example.py

@@ -18,8 +18,7 @@
 
 from rsocket.payload import Payload
 from rsocket.request_handler import BaseRequestHandler
-from rsocket.rsocket_server import RSocketServer
-from rsocket.transports.channels_transport import AsyncRSocketConsumer, rsocket_consumer_factory
+from rsocket.transports.channels_transport import rsocket_consumer_factory
 
 
 # Define a request handler for RSocket

examples/server_fastapi_websocket.py

@@ -26,4 +26,4 @@ async def endpoint(websocket: WebSocket):
 
 
 if __name__ == "__main__":
-    uvicorn.run(app, host="0.0.0.0", port=6565)
+    uvicorn.run(app, host="0.0.0.0", port=6565)

examples/tutorial/step6/chat_server.py

@@ -1,7 +1,7 @@
 import asyncio
 import logging
 import uuid
-from asyncio import Queue, Task
+from asyncio import Queue
 from collections import defaultdict
 from dataclasses import dataclass, field
 from typing import Dict, Optional, Set, Awaitable, Tuple

tests/rsocket/test_connection_lost.py

@@ -23,8 +23,8 @@
 from rsocket.transports.aioquic_transport import rsocket_connect, rsocket_serve
 from rsocket.transports.tcp import TransportTCP
 from rsocket.transports.transport import Transport
-from tests.rsocket.helpers import future_from_payload, IdentifiedHandlerFactory, \
-    IdentifiedHandler, force_closing_connection, ServerContainer
+from tests.rsocket.helpers import (future_from_payload, IdentifiedHandlerFactory,
+                                   IdentifiedHandler, force_closing_connection, ServerContainer)
 
 
 class ServerHandler(IdentifiedHandler):
@@ -240,7 +240,7 @@ async def transport_provider():
 
 
 async def start_websocket_service(waiter: asyncio.Event, container, port: int, generate_test_certificates):
-    from rsocket.transports.aiohttp_websocket import websocket_handler_factory, TransportAioHttpClient
+    from rsocket.transports.aiohttp_websocket import websocket_handler_factory
     from aiohttp.test_utils import RawTestServer
 
     index_iterator = iter(range(1, 3))

tests/rsocket/test_routing.py

@@ -159,7 +159,6 @@ async def response(metadata: CompositeMetadata):
         assert result.metadata == b'test.path'
 
 
-
 async def test_routed_request_response_properly_finished_accept_payload_and_metadata(lazy_pipe):
     router = RequestRouter()