From 5c49467e4513e260647a74f84042662d78ccdbc7 Mon Sep 17 00:00:00 2001
From: Sam Wilkins <samwilkins333@gmail.com>
Date: Wed, 18 Sep 2019 19:16:00 -0400
Subject: tweaks

---
 src/client/northstar/utils/Extensions.ts | 10 ++++++++--
 1 file changed, 8 insertions(+), 2 deletions(-)

(limited to 'src/client/northstar/utils')

diff --git a/src/client/northstar/utils/Extensions.ts b/src/client/northstar/utils/Extensions.ts
index ad3e06806..8254c775c 100644
--- a/src/client/northstar/utils/Extensions.ts
+++ b/src/client/northstar/utils/Extensions.ts
@@ -31,13 +31,19 @@ type BatchHandlerAsync<I> = (batch: I[], context: BatchContext) => Promise<void>
 type BatchConverter<I, O> = BatchConverterSync<I, O> | BatchConverterAsync<I, O>;
 type BatchHandler<I> = BatchHandlerSync<I> | BatchHandlerAsync<I>;
 type FixedBatcher = { batchSize: number } | { batchCount: number, mode?: Mode };
+interface ExecutorResult<A> {
+    updated: A;
+    makeNextBatch: boolean;
+}
 interface PredicateBatcher<I, A> {
-    executor: (element: I, accumulator: A | undefined) => A | undefined;
+    executor: (element: I, accumulator: A) => ExecutorResult<A>;
     initial: A;
+    persistAccumulator?: boolean;
 }
 interface PredicateBatcherAsync<I, A> {
-    executor: (element: I, accumulator: A | undefined) => Promise<A | undefined>;
+    executor: (element: I, accumulator: A) => Promise<ExecutorResult<A>>;
     initial: A;
+    persistAccumulator?: boolean;
 }
 type Batcher<I, A> = FixedBatcher | PredicateBatcher<I, A>;
 type BatcherAsync<I, A> = Batcher<I, A> | PredicateBatcherAsync<I, A>;
-- 
cgit v1.2.3-70-g09d2