Basic async integration with existing event streams