Skip to content

Commit

Permalink
bounded by default
Browse files Browse the repository at this point in the history
  • Loading branch information
tim-smart committed Jul 26, 2024
1 parent 9f3bc90 commit cb0720c
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 8 deletions.
5 changes: 0 additions & 5 deletions .changeset/cool-birds-exercise.md

This file was deleted.

6 changes: 3 additions & 3 deletions packages/effect/src/internal/stream.ts
Original file line number Diff line number Diff line change
Expand Up @@ -474,12 +474,12 @@ const queueFromBufferOptions = <A, E>(
return Queue.unbounded()
}
switch (options?.strategy) {
case "dropping":
return Queue.dropping(options.bufferSize ?? 16)
case "sliding":
return Queue.sliding(options.bufferSize ?? 16)
case "suspend":
return Queue.bounded(options.bufferSize ?? 16)
default:
return Queue.dropping(options?.bufferSize ?? 16)
return Queue.bounded(options?.bufferSize ?? 16)
}
}

Expand Down

0 comments on commit cb0720c

Please sign in to comment.