Add flatten, and experimental create() for imperative event pushing. Still needs abort/unsubscribe support