Skip to content

Commit 5524543

Browse files
committed
Fix incorrect type definition for KStream.branch()
1 parent 89f522f commit 5524543

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

index.d.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -245,7 +245,7 @@ declare module "kafka-streams" {
245245
fromMost(stream$: any): KStream;
246246
clone(): KStream;
247247
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[];
249249
close(): Promise<boolean>;
250250
}
251251

0 commit comments

Comments
 (0)