light9 Changeset - f2c6b39c155c

Changeset - f2c6b39c155c

Parent rev.

Child rev.

[Not reviewed]

default

0 2 0

drewp@bigasterisk.com - 20 months ago 2023-05-30 05:49:40
drewp@bigasterisk.com

fix messagesSend counter

2 files changed with 4 insertions and 3 deletions:

light9/web/RdfDbChannel.ts

light9/web/rdfdbclient.ts

0 comments (0 inline, 0 general)

light9/web/RdfDbChannel.ts

➞

Show inline comments

@@ @@ -52,6 +52,8 @@ export class RdfDbChannel { @@
+    }
     log("send patch to server, " + body.length + " bytes");
     this.ws.send(body);
     this.messagesSent++;
     this.updateStatus();
     return true;
+  }

light9/web/rdfdbclient.ts

➞

Show inline comments

 import debug from "debug";
 import { parseJsonPatch, Patch } from "./patch";
 import { RdfDbChannel } from "./RdfDbChannel";
-export const log = debug("rdfdbclient");
 const log = debug("rdfdbclient");
 export class RdfDbClient {
   private channel: RdfDbChannel;
@@ @@ -28,7 +28,6 @@ export class RdfDbClient { @@
       this.clearGraphOnNewConnection();
     });
     this.channel.serverMessage.subscribe((m) => {
       log('got server json', m.body)
       parseJsonPatch(m.body, (p: Patch) => {
         log('patch from server:', p.dump())
         if (p.isEmpty()) {
@@ @@ -51,7 +50,7 @@ export class RdfDbClient { @@
   async _continueSending() {
     // we could call this less often and coalesce patches together to optimize
     // the dragging cases.
+    // the dragging cases. See rdfdb 'compactPatches' and 'processInbox'.
     while (this._patchesToSend.length) {
       const patch = this._patchesToSend.splice(0, 1)[0];
       const json = await patch.toJsonPatch();

0 comments (0 inline, 0 general)