using stream definition annotations for async processing