flake8 cleanup

Author: jell-o-fishi

examples/bugs/issue_290/server.py

@@ -61,8 +61,10 @@ async def channel_response(payload: Payload, composite_metadata):
         publisher = ChannelPublisher()
         subscriber = ChannelSubscriber(publisher)
 
-        # WHY?: if passing received payload to ChannelSubscriber here can be processed before at ChannelPublisher "subscribe" method got subscriber
-        # in other words - we do "one_next()", it will be processed with some logic and result can be published with "publish()"
+        # WHY?: if passing received payload to ChannelSubscriber here can be processed
+        # before at ChannelPublisher "subscribe" method got subscriber
+        # in other words - we do "one_next()", it will be processed with some logic
+        # and a result can be published with "publish()"
         # subscriber.on_next(payload)
 
         return publisher, subscriber
@@ -88,7 +90,7 @@ async def websocket_handler(request):
 async def start_server():
     logging.basicConfig(level=logging.DEBUG)
 
-    print(f'Starting server at localhost: 7878')
+    print('Starting server at localhost: 7878')
 
     app = web.Application()
     app.add_routes(

rsocket/handlers/request_cahnnel_responder.py

@@ -1,6 +1,5 @@
 from rsocket.frame import Frame, RequestChannelFrame
 from rsocket.handlers.request_cahnnel_common import RequestChannelCommon
-from rsocket.helpers import payload_from_frame
 
 
 class RequestChannelResponder(RequestChannelCommon):

rsocket/transports/channels_transport.py

@@ -1,6 +1,6 @@
 import asyncio
 from contextlib import asynccontextmanager
-from typing import Optional, Dict, Any, Callable
+from typing import Optional, Callable
 
 from channels.generic.websocket import AsyncWebsocketConsumer