Simplify stream notification implementation