graphite/Sharkey
1
0
Fork 0
mirror of https://git.joinsharkey.org/Sharkey/Sharkey.git synced 2024-11-27 07:23:08 +02:00
Code Issues Projects Releases Packages Wiki Activity

[Client] Implement streaming buffering

Browse source
This commit is contained in:
syuilo 2017-03-21 18:14:59 +09:00
parent 4968efe101
commit 48386a8f68
1 changed files with 14 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
src/web/app/common/scripts/stream.js
View file

@ -16,6 +16,7 @@ class Connection {
this.state = 'initializing'; this.state = 'initializing';
this.me = me; this.me = me;
this.buffer = [];
const host = CONFIG.apiUrl.replace('http', 'ws'); const host = CONFIG.apiUrl.replace('http', 'ws');
this.socket = new ReconnectingWebSocket(`${host}?i=${me.token}`); this.socket = new ReconnectingWebSocket(`${host}?i=${me.token}`);
@ -29,6 +30,13 @@ class Connection {
onOpen() { onOpen() {
this.state = 'connected'; this.state = 'connected';
this.trigger('_connected_'); this.trigger('_connected_');
// バッファーを処理
const _buffer = [].concat(this.buffer); // Shallow copy
this.buffer = []; // Clear buffer
_buffer.forEach(message => {
this.send(message); // Resend each buffered messages
});
} }
onClose() { onClose() {
@ -46,8 +54,12 @@ class Connection {
} }
send(message) { send(message) {
// TODO: バッファリングしてつぎ接続した時に送信する // まだ接続が確立されていなかったらバッファリングして次に接続した時に送信する
if (this.state != 'connected') return; if (this.state != 'connected') {
this.buffer.push(message);
return;
};
this.socket.send(JSON.stringify(message)); this.socket.send(JSON.stringify(message));
} }