because primus substreams don't have pipes :(
pipe streams together and close all of them if one of them closes
TypeScript definitions for pump
Combine an array of streams into a single duplex stream using pump and duplexify
Clone a Readable stream, safely
[](https://github.com/substreams-js/substreams-js/actions/workflows/on-push-to-main.yaml) [](https://github.com/substreams-js/substreams-js/actions/workflows/on-push-to-main.yaml) [
Promise-enhancing wrapper for pump
Multiplexing of streams
Run an AI trading agent (any LLM provider) against Crucible Bench scenarios on 0G — single-command MCP+EIP-712 benchmark CLI.