feat: 🎸 simplify repo start method

Author: streamich

src/json-crdt-repo/__tests__/testbed.ts

@@ -71,7 +71,6 @@ export class BrowserTabTestbed {
       onSyncError: (error) => console.error(error),
       ...opts,
     });
-    repo.start();
     return new LocalRepoTestbed(this, repo);
   }
 

src/json-crdt-repo/local/level/LevelLocalRepo.ts

@@ -194,18 +194,14 @@ export class LevelLocalRepo implements LocalRepo {
     this.connected$ = opts.connected$ ?? new BehaviorSubject(true);
     this.pubsub = opts.pubsub ?? pubsub('level-local-repo');
     this.cipher = opts.cipher;
+    this._conSub = this.connected$.subscribe((connected) => {
+      if (connected && !this._remoteSyncLoopActive) this.runRemoteSyncLoop();
+    });
   }
 
   private _conSub: Subscription | undefined = undefined;
   private _stopped = false;
 
-  @once
-  public start(): void {
-    this._conSub = this.connected$.subscribe((connected) => {
-      if (!this._remoteSyncLoopActive) this.runRemoteSyncLoop();
-    });
-  }
-
   @once
   public stop(): void {
     this._remoteSyncLoopActive = false;

src/json-crdt-repo/local/level/__tests__/setup.ts

@@ -46,7 +46,6 @@ export const setup = async (
     return {kv, sid, local, pubsub, stop};
   };
   const {sid, local, pubsub, stop} = createLocal();
-  local.start();
   const createRemote = (localOpts: Partial<LevelLocalRepoOpts> = {}) => {
     const sid = localOpts.sid ?? 123456789;
     const busName = 'test-' + id;