futures-async-stream

• Added async_try_stream to support ? operator in async stream. e.g. You can write the following:

  #![feature(generators)]
  use futures::stream::Stream;
  use futures_async_stream::async_try_stream;
  
  #[async_try_stream(ok = i32, error = Box<dyn std::error::Error + Send + Sync>)]
  async fn foo(stream: impl Stream<Item = String>) {
      #[for_await]
      for x in stream {
          yield x.parse()?;
      }
  }
  

• Updated pin-project to 0.4.0-alpha.9.

• Pined the version of pin-project dependency

• Removed usage of some feature gates.

• Updated pin-project to 0.4.0-alpha.4.

• Updated proc-macro2, syn, and quote to 1.0.

• You can now use async stream functions in traits. e.g. You can write the following:

  #![feature(async_await, generators)]
  use futures_async_stream::async_stream;
  
  trait Foo {
      #[async_stream(boxed, item = u32)]
      async fn method(&mut self);
  }
  
  struct Bar(u32);
  
  impl Foo for Bar {
      #[async_stream(boxed, item = u32)]
      async fn method(&mut self) {
          while self.0 < u32::max_value() {
              self.0 += 1;
              yield self.0;
          }
      }
  }
  

Initial release