Simple streamable state machine that implements a useful channel, message-type, message pattern - View it on GitHub