futures_await_async_macro
pub fn async_stream( attribute: TokenStream, function: TokenStream) -> TokenStream