HF RL Explorer

Add a try flatten unordered combinator for streams of fallible streams.

Add a try flatten unordered combinator for streams of fallible streams.: a task in LegoFlow-SWE (Harbor dataset). Currently, StreamExt (and TryStreamExt ) provides flatten unordered for flattening a stream of streams with a concurrency limit, but there is no equivalent that works with fallible…

The task

Currently, `StreamExt` (and `TryStreamExt`) provides `flatten_unordered` for flattening a stream of streams with a concurrency limit, but there is no equivalent that works with fallible streams – i.e., streams whose items are `Result<St, E>` where `St` is itself a stream of `Result<T, E>`. The missing combinator…

Part of Lego-X/LegoFlow-SWE.