This is somewhat similar to the streaming producer/consumer from another rust crate: https://github.com/Geal/nom perhaps they could be interoperable.