Merge branch 'master' into graphql

Author: jell-o-fishi

requirements.txt

@@ -13,7 +13,7 @@ pytest-profiling==1.7.0
 pytest-rerunfailures==12.0
 pytest-timeout==2.1.0
 pytest-xdist==3.3.1
-pytest==7.4.0
+pytest==7.4.2
 quart==0.19.2
 reactivex==4.0.4
 starlette==0.31.1

rsocket/handlers/request_cahnnel_responder.py

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

tests/rsocket/test_request_channel.py

@@ -44,6 +44,7 @@ class Handler(BaseRequestHandler, DefaultPublisherSubscription, DefaultSubscribe
         def __init__(self):
             super().__init__()
             self.received_messages = []
+            self.channel_request = None
 
         def on_next(self, value, is_complete=False):
             self.received_messages.append(value)
@@ -59,6 +60,7 @@ def request(self, n: int):
             self._subscriber.on_complete()
 
         async def request_channel(self, payload: Payload) -> Tuple[Optional[Publisher], Optional[Subscriber]]:
+            self.channel_request = payload
             return self, self
 
     handler: Optional[Handler] = None
@@ -75,9 +77,10 @@ def handler_factory():
 
     server.set_handler_using_factory(handler_factory)
 
-    received_messages = await AwaitableRSocket(client).request_channel(Payload(), RequesterPublisher())
+    received_messages = await AwaitableRSocket(client).request_channel(Payload(b'channel request'), RequesterPublisher())
 
     await response_stream_finished.wait()
 
     assert len(received_messages) == 0
     assert len(handler.received_messages) == 0
+    assert handler.channel_request.data == b'channel request'