Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
9 changes: 1 addition & 8 deletions wasmsockets/client.py
Original file line number Diff line number Diff line change
Expand Up @@ -84,9 +84,7 @@ async def send(self, message):
Only pass in a str or a bytes-like object.
"""
if iswasm():
js.console.log(f"Sending message: {message}; checking for socket open")
await self._isopen.wait()
js.console.log(f"Socket now open; sending")
if isinstance(message, BytesLike):
data = pyodide.ffi.to_js(message)
else:
Expand All @@ -106,11 +104,8 @@ def send_sync(self, message):

async def recv(self):
if iswasm():
js.console.log(f"Receiving message; checking for socket open")
await self._isopen.wait()
js.console.log(f"Waiting to receive message...")
result = await self._incoming.get()
js.console.log(f"Message received: {result}")
else:
result = await self._pysocket.recv()
return result
Expand All @@ -137,12 +132,10 @@ def add_handlers(self, message_handler, wait_handler):
# JS callback handlers

async def _open_handler(self, event):
js.console.log(f"Open event: {event.to_py()}")
self._isopen.set()

async def _message_handler(self, event):
js.console.log(f"Message event: {event.data}")
await self._incoming.put(event.data)

async def _error_handler(self, event):
js.console.log(f"Error event: {event}")
js.console.error(f"Error event from websocket: {event}")
1 change: 0 additions & 1 deletion wasmsockets/worker.py
Original file line number Diff line number Diff line change
Expand Up @@ -37,7 +37,6 @@ def websockets_worker(url):
self.sync = msg.data.sync
self.receiving_port.onmessage = async e => {
const websocket = await self.socket_promise
console.log(`Sending ${e.data} over websocket`)
websocket.send(e.data)
}
}
Expand Down