more fixes
This commit is contained in:
parent
3cdb1bb8e1
commit
a45188c1fc
2 changed files with 10 additions and 12 deletions
|
@ -149,22 +149,21 @@ class Localuser {
|
||||||
w = ds.writable.getWriter();
|
w = ds.writable.getWriter();
|
||||||
r = ds.readable.getReader();
|
r = ds.readable.getReader();
|
||||||
arr = new Uint8Array();
|
arr = new Uint8Array();
|
||||||
|
const textdecode = new TextDecoder();
|
||||||
(async () => {
|
(async () => {
|
||||||
let temp;
|
|
||||||
while (true) {
|
while (true) {
|
||||||
const read = (await r.read());
|
const read = await r.read();
|
||||||
const data = new TextDecoder().decode(read.value);
|
const data = textdecode.decode(read.value);
|
||||||
build += data;
|
build += data;
|
||||||
try {
|
try {
|
||||||
temp = JSON.parse(build);
|
const temp = JSON.parse(build);
|
||||||
build = "";
|
build = "";
|
||||||
if (temp.op === 0 && temp.t === "READY") {
|
if (temp.op === 0 && temp.t === "READY") {
|
||||||
returny();
|
returny();
|
||||||
}
|
}
|
||||||
this.handleEvent(temp);
|
this.handleEvent(temp);
|
||||||
}
|
}
|
||||||
catch {
|
catch { }
|
||||||
}
|
|
||||||
}
|
}
|
||||||
})();
|
})();
|
||||||
}
|
}
|
||||||
|
|
|
@ -155,21 +155,20 @@ class Localuser{
|
||||||
w= ds.writable.getWriter();
|
w= ds.writable.getWriter();
|
||||||
r=ds.readable.getReader();
|
r=ds.readable.getReader();
|
||||||
arr=new Uint8Array();
|
arr=new Uint8Array();
|
||||||
|
const textdecode=new TextDecoder();
|
||||||
(async ()=>{
|
(async ()=>{
|
||||||
let temp:any;
|
|
||||||
while(true){
|
while(true){
|
||||||
const read=(await r.read());
|
const read=await r.read();
|
||||||
const data=new TextDecoder().decode(read.value);
|
const data=textdecode.decode(read.value);
|
||||||
build+=data;
|
build+=data;
|
||||||
try{
|
try{
|
||||||
temp=JSON.parse(build);
|
const temp=JSON.parse(build);
|
||||||
build="";
|
build="";
|
||||||
if(temp.op===0&&temp.t==="READY"){
|
if(temp.op===0&&temp.t==="READY"){
|
||||||
returny();
|
returny();
|
||||||
}
|
}
|
||||||
this.handleEvent(temp);
|
this.handleEvent(temp);
|
||||||
}catch{
|
}catch{}
|
||||||
}
|
|
||||||
}
|
}
|
||||||
})();
|
})();
|
||||||
}
|
}
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue