moon
/
ditto
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

streaming: socket.addEventListener('open', ...) --> socket.onopen, etc

This commit is contained in:
Alex Gleason 2023-08-25 17:17:26 -05:00
parent a93d77c851
commit 9da03aa053
No known key found for this signature in database
GPG Key ID: 7211D1F99744FBB7
1 changed files with 4 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/controllers/api/streaming.ts
View File

@ -42,8 +42,7 @@ const streamingController: AppController = (c) => {
}
}
socket.addEventListener('open', async () => {
console.log('websocket: connection opened');
socket.onopen = async () => {
if (!stream) return;
ws.subscribe(conn, { stream });
@ -58,14 +57,11 @@ const streamingController: AppController = (c) => {
}
}
}
});
};
socket.addEventListener('message', (e) => console.log('websocket message: ', e.data));
socket.addEventListener('close', () => {
console.log('websocket: connection closed');
socket.onclose = () => {
ws.unsubscribeAll(socket);
});
};
return response;
};