forked/h2
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

chore: async_await is stable on nightly

Browse Source
This commit is contained in:
Gurwinder Singh
2019-08-21 12:23:04 +05:30
committed by Sean McArthur
parent b2c5d7f0bb
commit 85b1f669c0
20 changed files with 0 additions and 51 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
examples/akamai.rs
View File

@@ -3,8 +3,6 @@ fn main() {
} }
/* /*
#![feature(async_await)]
use h2::client; use h2::client;
use futures::*; use futures::*;

2
examples/client.rs
View File

@@ -1,5 +1,3 @@
#![feature(async_await)]
use h2::client; use h2::client;
use http::{HeaderMap, Request}; use http::{HeaderMap, Request};

2
examples/server.rs
View File

@@ -1,5 +1,3 @@
#![feature(async_await)]
use h2::server; use h2::server;
use bytes::*; use bytes::*;

19
src/client.rs
View File

@@ -65,7 +65,6 @@
//! # Example //! # Example
//! //!
//! ```rust, no_run //! ```rust, no_run
//! #![feature(async_await)]
//! //!
//! use h2::client; //! use h2::client;
//! //!
@@ -212,7 +211,6 @@ pub struct ReadySendRequest<B: IntoBuf> {
/// # Examples /// # Examples
/// ///
/// ``` /// ```
/// # #![feature(async_await)]
/// # use tokio_io::*; /// # use tokio_io::*;
/// # use h2::client; /// # use h2::client;
/// # use h2::client::*; /// # use h2::client::*;
@@ -291,7 +289,6 @@ pub struct PushPromises {
/// # Examples /// # Examples
/// ///
/// ``` /// ```
/// # #![feature(async_await)]
/// # use tokio_io::*; /// # use tokio_io::*;
/// # use h2::client::*; /// # use h2::client::*;
/// # use bytes::Bytes; /// # use bytes::Bytes;
@@ -373,7 +370,6 @@ where
/// # Examples /// # Examples
/// ///
/// ```rust /// ```rust
/// # #![feature(async_await)]
/// # use h2::client::*; /// # use h2::client::*;
/// # use http::*; /// # use http::*;
/// # async fn doc(send_request: SendRequest<&'static [u8]>) /// # async fn doc(send_request: SendRequest<&'static [u8]>)
@@ -433,7 +429,6 @@ where
/// Sending a request with no body /// Sending a request with no body
/// ///
/// ```rust /// ```rust
/// # #![feature(async_await)]
/// # use h2::client::*; /// # use h2::client::*;
/// # use http::*; /// # use http::*;
/// # async fn doc(send_request: SendRequest<&'static [u8]>) /// # async fn doc(send_request: SendRequest<&'static [u8]>)
@@ -458,7 +453,6 @@ where
/// Sending a request with a body and trailers /// Sending a request with a body and trailers
/// ///
/// ```rust /// ```rust
/// # #![feature(async_await)]
/// # use h2::client::*; /// # use h2::client::*;
/// # use http::*; /// # use http::*;
/// # async fn doc(send_request: SendRequest<&'static [u8]>) /// # async fn doc(send_request: SendRequest<&'static [u8]>)
@@ -604,7 +598,6 @@ impl Builder {
/// # Examples /// # Examples
/// ///
/// ``` /// ```
/// # #![feature(async_await)]
/// # use tokio_io::*; /// # use tokio_io::*;
/// # use h2::client::*; /// # use h2::client::*;
/// # use bytes::Bytes; /// # use bytes::Bytes;
@@ -647,7 +640,6 @@ impl Builder {
/// # Examples /// # Examples
/// ///
/// ``` /// ```
/// # #![feature(async_await)]
/// # use tokio_io::*; /// # use tokio_io::*;
/// # use h2::client::*; /// # use h2::client::*;
/// # use bytes::Bytes; /// # use bytes::Bytes;
@@ -683,7 +675,6 @@ impl Builder {
/// # Examples /// # Examples
/// ///
/// ``` /// ```
/// # #![feature(async_await)]
/// # use tokio_io::*; /// # use tokio_io::*;
/// # use h2::client::*; /// # use h2::client::*;
/// # use bytes::Bytes; /// # use bytes::Bytes;
@@ -718,7 +709,6 @@ impl Builder {
/// # Examples /// # Examples
/// ///
/// ``` /// ```
/// # #![feature(async_await)]
/// # use tokio_io::*; /// # use tokio_io::*;
/// # use h2::client::*; /// # use h2::client::*;
/// # use bytes::Bytes; /// # use bytes::Bytes;
@@ -759,7 +749,6 @@ impl Builder {
/// # Examples /// # Examples
/// ///
/// ``` /// ```
/// # #![feature(async_await)]
/// # use tokio_io::*; /// # use tokio_io::*;
/// # use h2::client::*; /// # use h2::client::*;
/// # use bytes::Bytes; /// # use bytes::Bytes;
@@ -809,7 +798,6 @@ impl Builder {
/// # Examples /// # Examples
/// ///
/// ``` /// ```
/// # #![feature(async_await)]
/// # use tokio_io::*; /// # use tokio_io::*;
/// # use h2::client::*; /// # use h2::client::*;
/// # use bytes::Bytes; /// # use bytes::Bytes;
@@ -851,7 +839,6 @@ impl Builder {
/// # Examples /// # Examples
/// ///
/// ``` /// ```
/// # #![feature(async_await)]
/// # use tokio_io::*; /// # use tokio_io::*;
/// # use h2::client::*; /// # use h2::client::*;
/// # use bytes::Bytes; /// # use bytes::Bytes;
@@ -897,7 +884,6 @@ impl Builder {
/// # Examples /// # Examples
/// ///
/// ``` /// ```
/// # #![feature(async_await)]
/// # use tokio_io::*; /// # use tokio_io::*;
/// # use h2::client::*; /// # use h2::client::*;
/// # use bytes::Bytes; /// # use bytes::Bytes;
@@ -943,7 +929,6 @@ impl Builder {
/// # Examples /// # Examples
/// ///
/// ``` /// ```
/// # #![feature(async_await)]
/// # use tokio_io::*; /// # use tokio_io::*;
/// # use h2::client::*; /// # use h2::client::*;
/// # use std::time::Duration; /// # use std::time::Duration;
@@ -982,7 +967,6 @@ impl Builder {
/// # Examples /// # Examples
/// ///
/// ``` /// ```
/// # #![feature(async_await)]
/// # use tokio_io::*; /// # use tokio_io::*;
/// # use h2::client::*; /// # use h2::client::*;
/// # use std::time::Duration; /// # use std::time::Duration;
@@ -1042,7 +1026,6 @@ impl Builder {
/// Basic usage: /// Basic usage:
/// ///
/// ``` /// ```
/// # #![feature(async_await)]
/// # use tokio_io::*; /// # use tokio_io::*;
/// # use h2::client::*; /// # use h2::client::*;
/// # use bytes::Bytes; /// # use bytes::Bytes;
@@ -1064,7 +1047,6 @@ impl Builder {
/// type will be `&'static [u8]`. /// type will be `&'static [u8]`.
/// ///
/// ``` /// ```
/// # #![feature(async_await)]
/// # use tokio_io::*; /// # use tokio_io::*;
/// # use h2::client::*; /// # use h2::client::*;
/// # /// #
@@ -1119,7 +1101,6 @@ impl Default for Builder {
/// # Examples /// # Examples
/// ///
/// ``` /// ```
/// # #![feature(async_await)]
/// # use tokio_io::*; /// # use tokio_io::*;
/// # use h2::client; /// # use h2::client;
/// # use h2::client::*; /// # use h2::client::*;

1
src/lib.rs
View File

@@ -81,7 +81,6 @@
#![doc(html_root_url = "https://docs.rs/h2/0.1.25")] #![doc(html_root_url = "https://docs.rs/h2/0.1.25")]
#![deny(missing_debug_implementations, missing_docs)] #![deny(missing_debug_implementations, missing_docs)]
#![cfg_attr(test, deny(warnings))] #![cfg_attr(test, deny(warnings))]
#![feature(async_await)]
macro_rules! proto_err { macro_rules! proto_err {
(conn: $($msg:tt)+) => { (conn: $($msg:tt)+) => {

3
src/server.rs
View File

@@ -64,7 +64,6 @@
//! will use the HTTP/2.0 protocol without prior negotiation. //! will use the HTTP/2.0 protocol without prior negotiation.
//! //!
//! ```no_run //! ```no_run
//! #![feature(async_await)]
//! use h2::server; //! use h2::server;
//! use http::{Response, StatusCode}; //! use http::{Response, StatusCode};
//! use tokio::net::TcpListener; //! use tokio::net::TcpListener;
@@ -175,7 +174,6 @@ pub struct Handshake<T, B: IntoBuf = Bytes> {
/// # Examples /// # Examples
/// ///
/// ``` /// ```
/// # #![feature(async_await)]
/// # use tokio_io::*; /// # use tokio_io::*;
/// # use h2::server; /// # use h2::server;
/// # use h2::server::*; /// # use h2::server::*;
@@ -311,7 +309,6 @@ const PREFACE: [u8; 24] = *b"PRI * HTTP/2.0\r\n\r\nSM\r\n\r\n";
/// # Examples /// # Examples
/// ///
/// ``` /// ```
/// # #![feature(async_await)]
/// # use tokio_io::*; /// # use tokio_io::*;
/// # use h2::server; /// # use h2::server;
/// # use h2::server::*; /// # use h2::server::*;

2
src/share.rs
View File

@@ -268,7 +268,6 @@ impl<B: IntoBuf> SendStream<B> {
/// is sent. For example: /// is sent. For example:
/// ///
/// ```rust /// ```rust
/// # #![feature(async_await)]
/// # use h2::*; /// # use h2::*;
/// # async fn doc(mut send_stream: SendStream<&'static [u8]>) { /// # async fn doc(mut send_stream: SendStream<&'static [u8]>) {
/// send_stream.reserve_capacity(100); /// send_stream.reserve_capacity(100);
@@ -571,7 +570,6 @@ impl PingPong {
/// # Example /// # Example
/// ///
/// ``` /// ```
/// # #![feature(async_await)]
/// # async fn doc(mut ping_pong: h2::PingPong) { /// # async fn doc(mut ping_pong: h2::PingPong) {
/// // let mut ping_pong = ... /// // let mut ping_pong = ...
/// ///

1
tests/h2-fuzz/src/main.rs
View File

@@ -1,4 +1,3 @@
#![feature(async_await)]
use futures::future; use futures::future;
use futures::stream::FuturesUnordered; use futures::stream::FuturesUnordered;
use futures::Stream; use futures::Stream;

1
tests/h2-support/src/lib.rs
View File

@@ -1,4 +1,3 @@
#![feature(async_await)]
//! Utilities to support tests. //! Utilities to support tests.
#[macro_use] #[macro_use]

2
tests/h2-tests/tests/client_request.rs
View File

@@ -1,5 +1,3 @@
#![feature(async_await)]
use futures::future::{join, ready, select, Either}; use futures::future::{join, ready, select, Either};
use futures::stream::FuturesUnordered; use futures::stream::FuturesUnordered;
use futures::StreamExt; use futures::StreamExt;

2
tests/h2-tests/tests/codec_read.rs
View File

@@ -1,5 +1,3 @@
#![feature(async_await)]
use futures::future::join; use futures::future::join;
use h2_support::prelude::*; use h2_support::prelude::*;
use std::error::Error; use std::error::Error;

2
tests/h2-tests/tests/codec_write.rs
View File

@@ -1,5 +1,3 @@
#![feature(async_await)]
use futures::future::join; use futures::future::join;
use h2_support::prelude::*; use h2_support::prelude::*;

1
tests/h2-tests/tests/flow_control.rs
View File

@@ -1,4 +1,3 @@
#![feature(async_await)]
use futures::future::{join, join4}; use futures::future::{join, join4};
use futures::{StreamExt, TryStreamExt}; use futures::{StreamExt, TryStreamExt};
use h2_support::prelude::*; use h2_support::prelude::*;

2
tests/h2-tests/tests/hammer.rs
View File

@@ -1,5 +1,3 @@
#![feature(async_await)]
use futures::{FutureExt, StreamExt, TryFutureExt}; use futures::{FutureExt, StreamExt, TryFutureExt};
use h2_support::prelude::*; use h2_support::prelude::*;

2
tests/h2-tests/tests/ping_pong.rs
View File

@@ -1,5 +1,3 @@
#![feature(async_await)]
use futures::channel::oneshot; use futures::channel::oneshot;
use futures::future::join; use futures::future::join;
use futures::{StreamExt, TryStreamExt}; use futures::{StreamExt, TryStreamExt};

2
tests/h2-tests/tests/prioritization.rs
View File

@@ -1,5 +1,3 @@
#![feature(async_await)]
use futures::future::join; use futures::future::join;
use futures::{FutureExt, StreamExt}; use futures::{FutureExt, StreamExt};
use h2_support::prelude::*; use h2_support::prelude::*;

1
tests/h2-tests/tests/push_promise.rs
View File

@@ -1,4 +1,3 @@
#![feature(async_await)]
use futures::future::join; use futures::future::join;
use futures::{StreamExt, TryStreamExt}; use futures::{StreamExt, TryStreamExt};
use h2_support::prelude::*; use h2_support::prelude::*;

1
tests/h2-tests/tests/server.rs
View File

@@ -1,4 +1,3 @@
#![feature(async_await)]
#![deny(warnings)] #![deny(warnings)]
use futures::future::{join, poll_fn}; use futures::future::{join, poll_fn};

1
tests/h2-tests/tests/stream_states.rs
View File

@@ -1,4 +1,3 @@
#![feature(async_await)]
#![deny(warnings)] #![deny(warnings)]
use futures::future::{join, join3, lazy, try_join}; use futures::future::{join, join3, lazy, try_join};

2
tests/h2-tests/tests/trailers.rs
View File

@@ -1,5 +1,3 @@
#![feature(async_await)]
use futures::StreamExt; use futures::StreamExt;
use h2_support::prelude::*; use h2_support::prelude::*;