Break out memory features on emitters into its own class.
Add an abstraction for sending (and stopping) events between streams.