From 5524543a170a31579da66095046a1278b688e97f Mon Sep 17 00:00:00 2001 From: Patrick Virtualbox Date: Sat, 1 Jun 2019 04:01:37 +1000 Subject: [PATCH] Fix incorrect type definition for KStream.branch() --- index.d.ts | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/index.d.ts b/index.d.ts index 0b71926..7fc1b12 100644 --- a/index.d.ts +++ b/index.d.ts @@ -245,7 +245,7 @@ declare module "kafka-streams" { fromMost(stream$: any): KStream; clone(): KStream; window(from: number, to: number, etl?: null | ((message: any) => any), encapsulated?: boolean): { window: Window, abort: () => void, stream: KStream }; - branch(preds: (message: any) => boolean[]): KStream[]; + branch(preds: ((message: any) => boolean)[]): KStream[]; close(): Promise; }