code cleanup

Author: jell-o-fishi

examples/server_with_routing.py

@@ -73,7 +73,7 @@ async def metadata_push(payload: Payload, composite_metadata: CompositeMetadata)
                 storage.last_metadata_push = item.content
 
     @router.channel('channel')
-    async def channel_response(payload:Payload, composite_metadata):
+    async def channel_response(payload: Payload, composite_metadata):
         logging.info('Got channel request')
         subscriber = LoggingSubscriber()
         subscriber.on_next(payload)

tests/rsocket/test_request_stream.py

@@ -138,7 +138,7 @@ def on_error(self, exception: Exception):
 
     assert len(stream_subscriber.received_messages) == 1
     assert stream_subscriber.received_messages[0].data == b'success'
-    assert type(stream_subscriber.error) == RuntimeError
+    assert type(stream_subscriber.error) is RuntimeError
     assert str(stream_subscriber.error) == 'error message from handler'