This PR reimplements streams, with the main design being around a Logic implementation for each stage. It's not perfect yet, but it's an improvement over what was here before, and it lays the foundation to build the next stages, notably better error handling, and a feature called ports whereby logic can spawn arbitrary logic implementations, itself being both upstream and downstream for that logic.
There's ~5 implementation attempts in this PR, but given the latest commit it finally seems promising.
Additionally in this PR, futures and Tokio support are (temporarily removed). I'd like to focus on getting the core implementation solid, and hopefully by the time that has happened a new stable Tokio has been released.
This PR reimplements streams, with the main design being around a
Logicimplementation for each stage. It's not perfect yet, but it's an improvement over what was here before, and it lays the foundation to build the next stages, notably better error handling, and a feature called ports whereby logic can spawn arbitrary logic implementations, itself being both upstream and downstream for that logic.There's ~5 implementation attempts in this PR, but given the latest commit it finally seems promising.
Additionally in this PR, futures and Tokio support are (temporarily removed). I'd like to focus on getting the core implementation solid, and hopefully by the time that has happened a new stable Tokio has been released.