This utility function converts an RxJS Observable into a Web Streams API WritableStream.
Values emitted by the Observable will be written to the returned WritableStream. The stream
will close when the Observable completes or abort if the Observable errors.
Note: This function creates a new WritableStream. For directly subscribing to an Observable
and writing to an existing WritableStream, use subscribeToWritable instead.
Convert an RxJS Observable to a WritableStream.
This utility function converts an RxJS Observable into a Web Streams API WritableStream. Values emitted by the Observable will be written to the returned WritableStream. The stream will close when the Observable completes or abort if the Observable errors.
Note: This function creates a new WritableStream. For directly subscribing to an Observable and writing to an existing WritableStream, use subscribeToWritable instead.