Ignore comma at the end of stream

futures-async-stream-macro/src/parse.rs

@@ -121,6 +121,10 @@ impl Parse for FnOrAsync {
             attrs.append(&mut expr.attrs);
             expr.attrs = attrs;
 
+            if input.peek(Token![,]) {
+                let _: Token![,] = input.parse()?;
+            }
+
             Ok(Self::Async(expr, input.parse()?))
         } else {
             input.parse::<TokenStream>()?; // ignore all inputs

tests/stream.rs

@@ -5,7 +5,8 @@
     clippy::must_use_candidate,
     clippy::needless_lifetimes,
     clippy::no_effect_underscore_binding,
-    clippy::semicolon_if_nothing_returned
+    clippy::semicolon_if_nothing_returned,
+    clippy::unnecessary_wraps
 )] // broken
 #![feature(coroutines, proc_macro_hygiene, stmt_expr_attributes, gen_future)]
 
@@ -180,6 +181,15 @@ pub async fn array() {
     yield [1, 2, 3, 4];
 }
 
+pub fn some_stream() -> Option<impl Stream> {
+    Some(
+        #[stream]
+        async {
+            yield 1;
+        },
+    )
+}
+
 #[allow(clippy::toplevel_ref_arg)]
 pub mod arguments {
     use super::*;

tests/ui/threads-safety.stderr

@@ -16,7 +16,7 @@ note: required because it appears within the type `Box<dyn Stream<Item = i32>>`
 note: required because it appears within the type `Pin<Box<dyn Stream<Item = i32>>>`
   --> $RUST/core/src/pin.rs
    |
-   | pub struct Pin<Ptr> {
+   | pub struct Pin<P> {
    |            ^^^
 note: required by a bound in `assert_send`
   --> tests/ui/threads-safety.rs:7:19