Skip to content

Commit

Permalink
test: fix failing type test and improve typing in test
Browse files Browse the repository at this point in the history
  • Loading branch information
Arvid Nicolaas committed Feb 14, 2024
1 parent f288e25 commit 1ad227b
Show file tree
Hide file tree
Showing 2 changed files with 7 additions and 7 deletions.
6 changes: 3 additions & 3 deletions packages/stream/test-d/async-reducer.test-d.mts
Original file line number Diff line number Diff line change
Expand Up @@ -32,11 +32,11 @@ expectAssignable<Promise<{ a: number[]; s: number }>>(

// AsyncReducer.combineFirstDone
expectType<AsyncReducer<number, number | undefined>>(
AsyncReducer.combineFirstDone([Reducer.sum, Reducer.product])
AsyncReducer.race([Reducer.sum, Reducer.product])
);

expectType<AsyncReducer<number, number>>(
AsyncReducer.combineFirstDone([Reducer.sum, Reducer.product], 5)
AsyncReducer.race([Reducer.sum, Reducer.product], 5)
);

// AsyncReducer.groupBy
Expand Down Expand Up @@ -133,7 +133,7 @@ expectType<AsyncReducer<number, number[]>>(

// .takeOutputWhile
expectType<AsyncReducer<number, number[]>>(
AsyncReducer.from(Reducer.toArray<number>()).takeOutputWhile(() => true)
AsyncReducer.from(Reducer.toArray<number>()).takeOutputUntil(() => true)
);

// .mapInput
Expand Down
8 changes: 4 additions & 4 deletions packages/stream/test-d/reducer.test.mts
Original file line number Diff line number Diff line change
Expand Up @@ -22,19 +22,19 @@ expectAssignable<Reducer<number, { a: number[]; s: number }>>(
expectAssignable<{ a: number[]; s: number }>(
Stream.of(1, 2).reduce(
Reducer.combine({
a: Reducer.toArray(),
a: Reducer.toArray<number>(),
s: Reducer.sum,
})
)
);

// Reducer.combineFirstDone
expectType<Reducer<number, number | undefined>>(
Reducer.combineFirstDone([Reducer.sum, Reducer.product])
Reducer.race([Reducer.sum, Reducer.product])
);

expectType<Reducer<number, number>>(
Reducer.combineFirstDone([Reducer.sum, Reducer.product], 5)
Reducer.race([Reducer.sum, Reducer.product], 5)
);

// Reducer.groupBy
Expand Down Expand Up @@ -116,7 +116,7 @@ expectType<Reducer<number, number[]>>(Reducer.toArray<number>().takeOutput(5));

// .takeOutputWhile
expectType<Reducer<number, number[]>>(
Reducer.toArray<number>().takeOutputWhile(() => true)
Reducer.toArray<number>().takeOutputUntil(() => true)
);

// .mapInput
Expand Down

0 comments on commit 1ad227b

Please sign in to comment.