LumeWeb
/
kernel-protomux
Archived
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

use this.stream

This commit is contained in:
Derrick Hammer 2023-04-06 17:29:29 -04:00
parent 54904ab1ad
commit 1387b060a4
Signed by: pcfreak30
GPG Key ID: C997C339BE476FF2
1 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
index.js
View File

@ -779,20 +779,20 @@ module.exports = class Protomux {
}
async popFree(id) {
await this.userData.syncProtomux("popFree", id);
await this.stream.syncProtomux("popFree", id);
}
async pushFree(id) {
await this.userData.syncProtomux("pushFree", id);
await this.stream.syncProtomux("pushFree", id);
}
async pushLocal(id) {
await this.userData.syncProtomux("pushLocal", id);
await this.stream.syncProtomux("pushLocal", id);
}
async pushRemote(id) {
await this.userData.syncProtomux("pushRemote", id);
await this.stream.syncProtomux("pushRemote", id);
}
async pullLocal() {
const ids = await this.userData.syncProtomux("pullLocal");
const ids = await this.stream.syncProtomux("pullLocal");
ids.forEach((item) => {
item = parseInt(item);
@ -802,13 +802,13 @@ module.exports = class Protomux {
});
}
async pullFree() {
const ids = await this.userData.syncProtomux("pullFree");
const ids = await this.stream.syncProtomux("pullFree");
this._free = Array.from(new Set([...this._free, ...ids]));
this._free = this._free.filter((item) => item !== null);
}
async pullRemote() {
const ids = await this.userData.syncProtomux("pullRemote");
const ids = await this.stream.syncProtomux("pullRemote");
ids.forEach((item) => {
item = parseInt(item);