161sh/trashposs
1
0
Fork 0
mirror of https://iceshrimp.dev/crimekillz/trashposs synced 2024-11-23 01:13:48 +01:00
Code Issues Packages Projects Releases Wiki Activity

#928

Browse Source
This commit is contained in:
syuilo 2017-11-17 21:14:03 +09:00
parent ec430bc3b2
commit ebc039844a
1 changed files with 14 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
src/web/app/common/scripts/streaming/stream-manager.ts
View File

@ -9,6 +9,8 @@ import Connection from './stream';
export default abstract class StreamManager<T extends Connection> extends EventEmitter {
private _connection: T = null;
private disposeTimerId: any;
/**
* コネクションを必要としているユーザー
*/
@ -51,6 +53,12 @@ export default abstract class StreamManager<T extends Connection> extends EventE
* コネクションを要求するためのユーザーIDを発行します
*/
public use() {
// タイマー解除
if (this.disposeTimerId) {
clearTimeout(this.disposeTimerId);
this.disposeTimerId = null;
}
// ユーザーID生成
const userId = uuid();
@ -68,9 +76,12 @@ export default abstract class StreamManager<T extends Connection> extends EventE
// 誰もコネクションの利用者がいなくなったら
if (this.users.length == 0) {
// コネクションを切断する
this.connection.close();
this.connection = null;
// また直ぐに再利用される可能性があるので、一定時間待ち、
// 新たな利用者が現れなければコネクションを切断する
this.disposeTimerId = setTimeout(() => {
this.connection.close();
this.connection = null;
}, 3000);
}
}
}