Skip to content

Commit 2ac3042

Browse files
Make buffered_message_sender compatible with v1
1 parent 0b11aa7 commit 2ac3042

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

src/replit_river/common_session.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,6 +4,7 @@
44
from typing import Any, Awaitable, Callable, Coroutine, Protocol
55

66
from opentelemetry.trace import Span
7+
from websockets import WebSocketCommonProtocol
78
from websockets.asyncio.client import ClientConnection
89

910
from replit_river.messages import (
@@ -54,7 +55,7 @@ class SessionState(enum.Enum):
5455
async def buffered_message_sender(
5556
block_until_connected: Callable[[], Awaitable[None]],
5657
block_until_message_available: Callable[[], Awaitable[None]],
57-
get_ws: Callable[[], ClientConnection | None],
58+
get_ws: Callable[[], ClientConnection | WebSocketCommonProtocol | None],
5859
websocket_closed_callback: Callable[[], Coroutine[Any, Any, None]],
5960
get_next_pending: Callable[[], TransportMessage | None],
6061
commit: Callable[[TransportMessage], None],

0 commit comments

Comments
 (0)