cleanup
This commit is contained in:
parent
af36c71a59
commit
78fecd003a
3 changed files with 0 additions and 5 deletions
|
@ -28,9 +28,6 @@ export class DecryptionPreparation {
|
||||||
}
|
}
|
||||||
|
|
||||||
async decrypt() {
|
async decrypt() {
|
||||||
// console.log("start sleeping");
|
|
||||||
// await new Promise(resolve => setTimeout(resolve, 5000));
|
|
||||||
// console.log("done sleeping");
|
|
||||||
try {
|
try {
|
||||||
const errors = this._initialErrors;
|
const errors = this._initialErrors;
|
||||||
const results = new Map();
|
const results = new Map();
|
||||||
|
|
|
@ -102,7 +102,6 @@ export class Room extends EventEmitter {
|
||||||
const isTimelineOpen = this._isTimelineOpen;
|
const isTimelineOpen = this._isTimelineOpen;
|
||||||
r.preparation = await this._roomEncryption.prepareDecryptAll(events, source, isTimelineOpen, inboundSessionTxn);
|
r.preparation = await this._roomEncryption.prepareDecryptAll(events, source, isTimelineOpen, inboundSessionTxn);
|
||||||
if (r.cancelled) return;
|
if (r.cancelled) return;
|
||||||
// TODO: should this throw an AbortError?
|
|
||||||
const changes = await r.preparation.decrypt();
|
const changes = await r.preparation.decrypt();
|
||||||
r.preparation = null;
|
r.preparation = null;
|
||||||
if (r.cancelled) return;
|
if (r.cancelled) return;
|
||||||
|
|
|
@ -94,7 +94,6 @@ export class WorkerPool {
|
||||||
}
|
}
|
||||||
|
|
||||||
handleEvent(e) {
|
handleEvent(e) {
|
||||||
console.log("WorkerPool event", e);
|
|
||||||
if (e.type === "message") {
|
if (e.type === "message") {
|
||||||
const message = e.data;
|
const message = e.data;
|
||||||
const request = this._requests.get(message.replyToId);
|
const request = this._requests.get(message.replyToId);
|
||||||
|
|
Reference in a new issue