The Akka-streams wrapper which use it as the underlying library, but realize some kind of RxState instead of finite streams.