Patch Changes
-
#3734
88e85db
Thanks @mikearnaldi! - Ensure random numbers are correctly distributed -
#3717
83887ca
Thanks @mikearnaldi! - Consider async operation in runSync as a defect, add span based stack -
#3731
5266b6c
Thanks @patroza! - Improve DX of type errors from insidepipe
andflow
-
#3699
cdead5c
Thanks @jessekelly881! - added Stream.mergeWithTagCombines a struct of streams into a single stream of tagged values where the tag is the key of the struct.
import { Stream } from "effect" // Stream.Stream<{ _tag: "a"; value: number; } | { _tag: "b"; value: string; }> const stream = Stream.mergeWithTag( { a: Stream.make(0), b: Stream.make("") }, { concurrency: 1 } )