File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -160,8 +160,8 @@ export interface Stream<A> extends Source<A> {
160160 timestamp ( ) : Stream < TimeValue < A > > ;
161161 delay ( dt : number ) : Stream < A > ;
162162
163- // Note: Without higher-kinded types, this type cannot be written properly
164- await < B > ( ) : Stream < B > ;
163+ await < B > ( this : Stream < Promise < B > > ) : Stream < B > ;
164+ awaitPromises < B > ( this : Stream < Promise < B > > ) : Stream < B > ;
165165
166166 sample < B , C , R > (
167167 fn : ( b : B , c : C ) => R ,
@@ -340,6 +340,7 @@ export function delay<A>(dt: number, s: Stream<A>): Stream<A>;
340340
341341export function fromPromise < A > ( p : Promise < A > ) : Stream < A > ;
342342export function await < A > ( s : Stream < Promise < A > > ) : Stream < A > ;
343+ export function awaitPromises < A > ( s : Stream < Promise < A > > ) : Stream < A > ;
343344
344345export function sample < A , B , R > (
345346 fn : ( a : A , b : B ) => R ,
You can’t perform that action at this time.
0 commit comments