Skip to content

Commit af409cf

Browse files
authored
fix behaviour of Stream.partition to match the types (#4004)
1 parent 9139df9 commit af409cf

File tree

3 files changed

+8
-3
lines changed

3 files changed

+8
-3
lines changed

.changeset/forty-radios-exist.md

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,5 @@
1+
---
2+
"effect": patch
3+
---
4+
5+
fix behavour of Stream.partition to match the types

packages/effect/src/internal/stream.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4729,7 +4729,7 @@ export const partition: {
47294729
> =>
47304730
partitionEither(
47314731
self,
4732-
(a) => Effect.succeed(predicate(a) ? Either.left(a) : Either.right(a)),
4732+
(a) => Effect.succeed(predicate(a) ? Either.right(a) : Either.left(a)),
47334733
options
47344734
)
47354735
)

packages/effect/test/Stream/partitioning.test.ts

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@ describe("Stream", () => {
3131
const { result1, result2 } = yield* $(
3232
Stream.range(0, 5),
3333
Stream.partition((n) => n % 2 === 0),
34-
Effect.flatMap(([evens, odds]) =>
34+
Effect.flatMap(([odds, evens]) =>
3535
Effect.all({
3636
result1: Stream.runCollect(evens),
3737
result2: Stream.runCollect(odds)
@@ -66,7 +66,7 @@ describe("Stream", () => {
6666
const { result1, result2, result3 } = yield* $(
6767
Stream.range(0, 5),
6868
Stream.partition((n) => (n % 2 === 0), { bufferSize: 1 }),
69-
Effect.flatMap(([evens, odds]) =>
69+
Effect.flatMap(([odds, evens]) =>
7070
Effect.gen(function*($) {
7171
const ref = yield* $(Ref.make(Chunk.empty<number>()))
7272
const latch = yield* $(Deferred.make<void>())

0 commit comments

Comments
 (0)