From d33d8dcad39bc83cb58e48131dcb42c7d0c4d69f Mon Sep 17 00:00:00 2001
From: Jerry Kurian <jerrykurian@protonmail.com>
Date: Mon, 9 Sep 2019 15:15:40 -0400
Subject: [PATCH] Add generic type

---
 src/functions/accumulator.ts | 2 +-
 src/functions/demux.ts       | 1 +
 2 files changed, 2 insertions(+), 1 deletion(-)

diff --git a/src/functions/accumulator.ts b/src/functions/accumulator.ts
index b8faeab..c406afe 100644
--- a/src/functions/accumulator.ts
+++ b/src/functions/accumulator.ts
@@ -17,7 +17,7 @@ function _accumulator<T>(
     const buffer: T[] = [];
     return new Transform({
         ...options,
-        transform(data: any, encoding, callback) {
+        transform(data: T, encoding, callback) {
             try {
                 accumulateBy(data, buffer, this);
                 callback();
diff --git a/src/functions/demux.ts b/src/functions/demux.ts
index 647cd61..a72eb69 100644
--- a/src/functions/demux.ts
+++ b/src/functions/demux.ts
@@ -118,6 +118,7 @@ class Demux extends Writable {
         }
         return this;
     }
+
     public once(event: string, cb: any) {
         switch (eventsTarget[event]) {
             case EventSubscription.Self: