Modeling Bidirectional Data Pipelines in Effect Typescript
Is there a suggested pattern for modeling bidirectional data pipelines?
With
https://pipecat-ai.github.io/pipecat/architecture.html
I could build a custom abstraction for this on top of
With
Stream it’s easy to define a pipeline where data flows in one direction. However, I’d like to model a pipeline where each step can send/receive data either upstream or downstream, akin to Pipecat’s architecture:https://pipecat-ai.github.io/pipecat/architecture.html
I could build a custom abstraction for this on top of
Queue, but I’m wondering if there’s a standard module for this where I can just pipe some processors together.
