feat: add pending write queue to record core

deepstreamIO · Dec 12, 2017 · 3b7b1c8 · 3b7b1c8
1 parent e2805fc
commit 3b7b1c8
Show file tree

Hide file tree

Showing 4 changed files with 73 additions and 3 deletions.
diff --git a/dist/src/record/record-core.d.ts b/dist/src/record/record-core.d.ts
@@ -39,6 +39,7 @@ export declare class RecordCore extends Emitter {
     private deletedTimeout;
     private deleteResponse;
     private whenComplete;
+    private pendingWrites;
     constructor(name: string, services: Services, options: Options, recordServices: RecordServices, whenComplete: (recordName: string) => void);
     readonly recordState: RECORD_STATE;
     usages: number;
@@ -130,6 +131,7 @@ export declare class RecordCore extends Emitter {
     private onResubscribing();
     private onOfflineLoading();
     private onReady();
+    private applyPendingWrites();
     private onUnsubscribed();
     private onDeleted();
     handle(message: RecordMessage): void;

diff --git a/dist/src/record/record-core.js b/dist/src/record/record-core.js