Merge pull request #116 from patricknazar/fix-branch-def-typo

krystianity · web-flow · commit a7c8a88c69f9 · 2019-06-02T23:18:59.000+02:00
Fix incorrect type definition for KStream.branch()
diff --git 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<boolean>;
     }
 

Original file line number	Diff line number	Diff line change
`@@ -245,7 +245,7 @@ declare module "kafka-streams" {`
`245`	`245`	`fromMost(stream$: any): KStream;`
`246`	`246`	`clone(): KStream;`
`247`	`247`	`window(from: number, to: number, etl?: null \| ((message: any) => any), encapsulated?: boolean): { window: Window, abort: () => void, stream: KStream };`
`248`		`- branch(preds: (message: any) => boolean[]): KStream[];`
	`248`	`+ branch(preds: ((message: any) => boolean)[]): KStream[];`
`249`	`249`	`close(): Promise<boolean>;`
`250`	`250`	`}`
`251`	`251`