- groupBy<A, K>(keyFn: ((a: A) => K), bufferSize?: number): (<E>(self: Source<A, E>) => Source<readonly [Source<A, E>, K, A], E>)
-
Parameters
-
keyFn: ((a: A) => K)
-
Optional
bufferSize: number
Returns (<E>(self: Source<A, E>) => Source<readonly [Source<A, E>, K, A], E>)