|
|
@@ -54,6 +54,8 @@ export class Source<T> extends LinearShape<T> {
|
|
|
return new Source(SizeLimitedStreamBuilder(this.builder, elements))
|
|
|
}
|
|
|
|
|
|
+ statefulMapConcat<O>(mapConcatFunction: () => [(v: T) => O[], () => O[]]): Source<O>
|
|
|
+ statefulMapConcat<O>(mapConcatFunction: () => (v: T) => O[]): Source<O>
|
|
|
statefulMapConcat<O>(mapConcatFunction: (() => (v: T) => O[]) | (() => [(v: T) => O[], () => O[]])): Source<O> {
|
|
|
return new Source(StatefulStreamBuilder(this.builder, mapConcatFunction))
|
|
|
}
|