fixed starlette/fastapi example.

Author: jell-o-fishi

examples/server_aiohttp_websocket.py

@@ -4,7 +4,7 @@
 import asyncclick as click
 from aiohttp import web
 
-from examples.fixtures import generate_certificate_and_key
+from fixtures import generate_certificate_and_key
 from rsocket.helpers import create_future
 from rsocket.local_typing import Awaitable
 from rsocket.payload import Payload

examples/server_fastapi_websocket.py

@@ -21,7 +21,7 @@ async def request_response(self, payload: Payload) -> Awaitable[Payload]:
 async def endpoint(websocket: WebSocket):
     await websocket.accept()
     transport = Http3TransportWebsocket(websocket)
-    RSocketServer(transport=transport)
+    RSocketServer(transport=transport, handler_factory=Handler)
     await transport.wait_for_disconnect()
 
 

rsocket/transports/http3_transport.py

@@ -164,7 +164,7 @@ def __init__(self, websocket: Union[WebSocket, ClientWebSocket]):
     async def send_frame(self, frame: Frame):
         with wrap_transport_exception():
             try:
-                data = serialize_with_frame_size_header(frame)
+                data = frame.serialize()
                 try:
                     await self._websocket.send_bytes(data)
                 except LocalProtocolError as exception:
@@ -190,7 +190,7 @@ async def incoming_data_listener(self):
                     self._disconnect_event.set()
                     break
 
-                async for frame in self._frame_parser.receive_data(data):
+                async for frame in self._frame_parser.receive_data(data, 0):
                     self._incoming_frame_queue.put_nowait(frame)
 
         except asyncio.CancelledError: