それこそmaterializeで簡単にEvent<T>のストリームに出来るんでそれ良さそう