From c72ecaf219271e24679d2860373234a0cc5b3ee0 Mon Sep 17 00:00:00 2001
From: Jerry Kurian <jerrykurian@protonmail.com>
Date: Mon, 12 Aug 2019 12:08:42 -0400
Subject: [PATCH] Add FlushStrategy as enum

---
 src/functions/index.ts | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/src/functions/index.ts b/src/functions/index.ts
index 5599934..6265a92 100644
--- a/src/functions/index.ts
+++ b/src/functions/index.ts
@@ -7,6 +7,7 @@ import {
     TransformOptions,
     WithEncoding,
     JsonParseOptions,
+    FlushStrategy,
 } from "./definitions";
 
 /**
@@ -249,7 +250,7 @@ export function parallelMap<T, R>(
 export function accumulator(
     batchSize: number,
     batchRate: number | undefined,
-    flushStrategy: "sliding" | "rolling",
+    flushStrategy: FlushStrategy,
     keyBy?: string,
 ) {
     return baseFunctions.accumulator(