Skip to content

Commit da3d9a4

Browse files
authored
Update core.py
Add WebSocket
1 parent 396535f commit da3d9a4

File tree

1 file changed

+8
-1
lines changed

1 file changed

+8
-1
lines changed

starlette_plus/core.py

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -27,6 +27,7 @@
2727
from starlette.responses import Response
2828
from starlette.routing import Mount, Route, WebSocketRoute
2929
from starlette.types import Receive, Scope, Send
30+
from starlette.websockets import WebSocket
3031

3132
from .types_.core import RouteCoro
3233

@@ -95,7 +96,13 @@ def __init__(self, **kwargs: Unpack[RouteOptions]) -> None:
9596
self._include_in_schema: bool = kwargs["include_in_schema"]
9697

9798
async def __call__(self, scope: Scope, receive: Receive, send: Send) -> Any:
98-
request: Request = Request(scope, receive, send)
99+
request: Request | WebSocket
100+
101+
if self._is_websocket:
102+
request = WebSocket(scope, receive, send)
103+
else:
104+
request = Request(scope, receive, send)
105+
99106
response: Response | None = await self._coro(self._view, request)
100107

101108
if not response:

0 commit comments

Comments
 (0)