[INFO] crate parallel-stream 2.1.1 is already in cache
[INFO] documenting parallel-stream-2.1.1 against try#66dfc4e010913fbed0c4ea91fc2c010004b0f441 for pr-73566
[INFO] extracting crate parallel-stream 2.1.1 into /workspace/builds/worker-3/source
[INFO] validating manifest of crates.io crate parallel-stream 2.1.1 on toolchain 66dfc4e010913fbed0c4ea91fc2c010004b0f441
[INFO] running `Command { std: "/workspace/cargo-home/bin/cargo" "+66dfc4e010913fbed0c4ea91fc2c010004b0f441" "read-manifest" "--manifest-path" "Cargo.toml", kill_on_drop: false }`
[INFO] started tweaking crates.io crate parallel-stream 2.1.1
[INFO] finished tweaking crates.io crate parallel-stream 2.1.1
[INFO] tweaked toml for crates.io crate parallel-stream 2.1.1 written to /workspace/builds/worker-3/source/Cargo.toml
[INFO] running `Command { std: "/workspace/cargo-home/bin/cargo" "+66dfc4e010913fbed0c4ea91fc2c010004b0f441" "generate-lockfile" "--manifest-path" "Cargo.toml" "-Zno-index-update", kill_on_drop: false }`
[INFO] running `Command { std: "/workspace/cargo-home/bin/cargo" "+66dfc4e010913fbed0c4ea91fc2c010004b0f441" "fetch" "--locked" "--manifest-path" "Cargo.toml", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-3/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-3/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "MAP_USER_ID=0" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--network" "none" "rustops/crates-build-env@sha256:819119df93c0f5eca3f29186f14981ef29945a311854d7222af07488600a2584" "/opt/rustwide/cargo-home/bin/cargo" "+66dfc4e010913fbed0c4ea91fc2c010004b0f441" "metadata" "--no-deps" "--format-version=1", kill_on_drop: false }`
[INFO] [stdout] a70986c7a614a8eb48fe830c2b169595a49ba61f61a8764a2df521ee7c773cb1
[INFO] [stderr] WARNING: Your kernel does not support swap limit capabilities or the cgroup is not mounted. Memory limited without swap.
[INFO] running `Command { std: "docker" "start" "-a" "a70986c7a614a8eb48fe830c2b169595a49ba61f61a8764a2df521ee7c773cb1", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "inspect" "a70986c7a614a8eb48fe830c2b169595a49ba61f61a8764a2df521ee7c773cb1", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "a70986c7a614a8eb48fe830c2b169595a49ba61f61a8764a2df521ee7c773cb1", kill_on_drop: false }`
[INFO] [stdout] a70986c7a614a8eb48fe830c2b169595a49ba61f61a8764a2df521ee7c773cb1
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-3/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-3/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "MAP_USER_ID=0" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTDOCFLAGS=--cap-lints=forbid" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--network" "none" "rustops/crates-build-env@sha256:819119df93c0f5eca3f29186f14981ef29945a311854d7222af07488600a2584" "/opt/rustwide/cargo-home/bin/cargo" "+66dfc4e010913fbed0c4ea91fc2c010004b0f441" "doc" "--frozen" "--no-deps" "--document-private-items" "--message-format=json", kill_on_drop: false }`
[INFO] [stdout] 1e91cfa55748f9c8d75303d0406d54d4df3f33ef8c097141cbb71cd4f1b0d9de
[INFO] [stderr] WARNING: Your kernel does not support swap limit capabilities or the cgroup is not mounted. Memory limited without swap.
[INFO] running `Command { std: "docker" "start" "-a" "1e91cfa55748f9c8d75303d0406d54d4df3f33ef8c097141cbb71cd4f1b0d9de", kill_on_drop: false }`
[INFO] [stderr]    Compiling proc-macro2 v1.0.18
[INFO] [stderr]    Compiling syn v1.0.33
[INFO] [stderr]    Compiling log v0.4.8
[INFO] [stderr]    Compiling wasm-bindgen-shared v0.2.64
[INFO] [stderr]    Compiling bumpalo v3.4.0
[INFO] [stderr]    Compiling wasm-bindgen v0.2.64
[INFO] [stderr]     Checking futures-core v0.3.5
[INFO] [stderr]    Compiling pin-project-internal v0.4.22
[INFO] [stderr]    Compiling libc v0.2.71
[INFO] [stderr]     Checking once_cell v1.4.0
[INFO] [stderr]     Checking slab v0.4.2
[INFO] [stderr]     Checking pin-utils v0.1.0
[INFO] [stderr]    Compiling autocfg v1.0.0
[INFO] [stderr]     Checking send_wrapper v0.4.0
[INFO] [stderr]     Checking pin-project-lite v0.1.7
[INFO] [stderr]     Checking futures-channel v0.3.5
[INFO] [stderr]     Checking futures-task v0.3.5
[INFO] [stderr]    Compiling crossbeam-utils v0.7.2
[INFO] [stderr]     Checking kv-log-macro v1.0.6
[INFO] [stderr]     Checking socket2 v0.3.12
[INFO] [stderr]     Checking num_cpus v1.13.0
[INFO] [stderr]    Compiling quote v1.0.7
[INFO] [stderr]    Compiling wasm-bindgen-backend v0.2.64
[INFO] [stderr]    Compiling wasm-bindgen-macro-support v0.2.64
[INFO] [stderr]    Compiling async-attributes v1.1.1
[INFO] [stderr]    Compiling wasm-bindgen-macro v0.2.64
[INFO] [stderr]     Checking js-sys v0.3.41
[INFO] [stderr]     Checking pin-project v0.4.22
[INFO] [stderr]     Checking futures-util v0.3.5
[INFO] [stderr]     Checking web-sys v0.3.41
[INFO] [stderr]     Checking blocking v0.4.6
[INFO] [stderr]     Checking smol v0.1.18
[INFO] [stderr]     Checking gloo-timers v0.2.1
[INFO] [stderr]     Checking futures-timer v3.0.2
[INFO] [stderr]     Checking async-std v1.6.2
[INFO] [stderr]  Documenting parallel-stream v2.1.1 (/opt/rustwide/workdir)
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]   --> src/from_stream.rs:24:1
[INFO] [stdout]    |
[INFO] [stdout] 24 | /// Converts a stream into a parallel stream.
[INFO] [stdout]    | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout] note: the lint level is defined here
[INFO] [stdout]   --> src/lib.rs:45:23
[INFO] [stdout]    |
[INFO] [stdout] 45 | #![warn(missing_docs, missing_doc_code_examples)]
[INFO] [stdout]    |                       ^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]   --> src/from_parallel_stream.rs:1:1
[INFO] [stdout]    |
[INFO] [stdout] 1  | / use core::future::Future;
[INFO] [stdout] 2  | | use core::pin::Pin;
[INFO] [stdout] 3  | |
[INFO] [stdout] 4  | | use crate::IntoParallelStream;
[INFO] [stdout] ...  |
[INFO] [stdout] 24 | |     .await;
[INFO] [stdout] 25 | | }
[INFO] [stdout]    | |_^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]  --> src/from_parallel_stream.rs:6:1
[INFO] [stdout]   |
[INFO] [stdout] 6 | /// Conversion from a `ParallelStream`.
[INFO] [stdout]   | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]  --> src/from_parallel_stream.rs:8:5
[INFO] [stdout]   |
[INFO] [stdout] 8 |     /// Creates a value from a stream.
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]   --> src/from_stream.rs:1:1
[INFO] [stdout]    |
[INFO] [stdout] 1  | / use core::pin::Pin;
[INFO] [stdout] 2  | |
[INFO] [stdout] 3  | | use async_std::stream::{IntoStream, Stream};
[INFO] [stdout] 4  | | use async_std::task::{Context, Poll};
[INFO] [stdout] ...  |
[INFO] [stdout] 53 | |     }
[INFO] [stdout] 54 | | }
[INFO] [stdout]    | |_^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]   --> src/from_stream.rs:24:1
[INFO] [stdout]    |
[INFO] [stdout] 24 | /// Converts a stream into a parallel stream.
[INFO] [stdout]    | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]   --> src/into_parallel_stream.rs:1:1
[INFO] [stdout]    |
[INFO] [stdout] 1  | / use crate::ParallelStream;
[INFO] [stdout] 2  | |
[INFO] [stdout] 3  | | /// Conversion into a `ParallelStream`.
[INFO] [stdout] 4  | | pub trait IntoParallelStream {
[INFO] [stdout] ...  |
[INFO] [stdout] 22 | |     }
[INFO] [stdout] 23 | | }
[INFO] [stdout]    | |_^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]  --> src/into_parallel_stream.rs:3:1
[INFO] [stdout]   |
[INFO] [stdout] 3 | /// Conversion into a `ParallelStream`.
[INFO] [stdout]   | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]  --> src/into_parallel_stream.rs:5:5
[INFO] [stdout]   |
[INFO] [stdout] 5 |     /// The type of the elements being iterated over.
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]  --> src/into_parallel_stream.rs:8:5
[INFO] [stdout]   |
[INFO] [stdout] 8 |     /// Which kind of stream are we turning this into?
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]   --> src/into_parallel_stream.rs:11:5
[INFO] [stdout]    |
[INFO] [stdout] 11 |     /// Creates a parallel stream from a value.
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]   --> src/par_stream/mod.rs:1:1
[INFO] [stdout]    |
[INFO] [stdout] 1  | / use async_std::future::Future;
[INFO] [stdout] 2  | | use async_std::task::{Context, Poll};
[INFO] [stdout] 3  | |
[INFO] [stdout] 4  | | use std::pin::Pin;
[INFO] [stdout] ...  |
[INFO] [stdout] 77 | |     }
[INFO] [stdout] 78 | | }
[INFO] [stdout]    | |_^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]  --> src/par_stream/mod.rs:8:1
[INFO] [stdout]   |
[INFO] [stdout] 8 | pub use for_each::ForEach;
[INFO] [stdout]   | ^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]  --> src/par_stream/mod.rs:9:1
[INFO] [stdout]   |
[INFO] [stdout] 9 | pub use map::Map;
[INFO] [stdout]   | ^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]   --> src/par_stream/mod.rs:10:1
[INFO] [stdout]    |
[INFO] [stdout] 10 | pub use next::NextFuture;
[INFO] [stdout]    | ^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]   --> src/par_stream/mod.rs:11:1
[INFO] [stdout]    |
[INFO] [stdout] 11 | pub use take::Take;
[INFO] [stdout]    | ^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]   --> src/par_stream/for_each.rs:1:1
[INFO] [stdout]    |
[INFO] [stdout] 1  | / use async_std::prelude::*;
[INFO] [stdout] 2  | | use async_std::sync::{self, Receiver, Sender};
[INFO] [stdout] 3  | | use async_std::task::{self, Context, Poll};
[INFO] [stdout] 4  | |
[INFO] [stdout] ...  |
[INFO] [stdout] 92 | |         .await;
[INFO] [stdout] 93 | | }
[INFO] [stdout]    | |_^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]   --> src/par_stream/for_each.rs:25:1
[INFO] [stdout]    |
[INFO] [stdout] 25 | / impl ForEach {
[INFO] [stdout] 26 | |     /// Create a new instance of `ForEach`.
[INFO] [stdout] 27 | |     pub fn new<S, F, Fut>(mut stream: S, mut f: F) -> Self
[INFO] [stdout] 28 | |     where
[INFO] [stdout] ...  |
[INFO] [stdout] 70 | |     }
[INFO] [stdout] 71 | | }
[INFO] [stdout]    | |_^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]   --> src/par_stream/for_each.rs:26:5
[INFO] [stdout]    |
[INFO] [stdout] 26 |     /// Create a new instance of `ForEach`.
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]   --> src/par_stream/map.rs:2:1
[INFO] [stdout]    |
[INFO] [stdout] 2  | / use async_std::future::Future;
[INFO] [stdout] 3  | | use async_std::sync::{self, Receiver};
[INFO] [stdout] 4  | | use async_std::task;
[INFO] [stdout] 5  | |
[INFO] [stdout] ...  |
[INFO] [stdout] 71 | |     assert_eq!(output, vec![10usize; 3]);
[INFO] [stdout] 72 | | }
[INFO] [stdout]    | |_^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]   --> src/par_stream/map.rs:21:1
[INFO] [stdout]    |
[INFO] [stdout] 21 | / impl<T: Send + 'static> Map<T> {
[INFO] [stdout] 22 | |     /// Create a new instance of `Map`.
[INFO] [stdout] 23 | |     pub fn new<S, F, Fut>(mut stream: S, mut f: F) -> Self
[INFO] [stdout] 24 | |     where
[INFO] [stdout] ...  |
[INFO] [stdout] 41 | |     }
[INFO] [stdout] 42 | | }
[INFO] [stdout]    | |_^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]   --> src/par_stream/map.rs:22:5
[INFO] [stdout]    |
[INFO] [stdout] 22 |     /// Create a new instance of `Map`.
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]   --> src/par_stream/next.rs:1:1
[INFO] [stdout]    |
[INFO] [stdout] 1  | / use core::future::Future;
[INFO] [stdout] 2  | | use core::pin::Pin;
[INFO] [stdout] 3  | | use core::task::{Context, Poll};
[INFO] [stdout] 4  | |
[INFO] [stdout] ...  |
[INFO] [stdout] 24 | |     }
[INFO] [stdout] 25 | | }
[INFO] [stdout]    | |_^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]   --> src/par_stream/take.rs:1:1
[INFO] [stdout]    |
[INFO] [stdout] 1  | / use core::pin::Pin;
[INFO] [stdout] 2  | | use core::task::{Context, Poll};
[INFO] [stdout] 3  | |
[INFO] [stdout] 4  | | use async_std::task::ready;
[INFO] [stdout] ...  |
[INFO] [stdout] 60 | |     }
[INFO] [stdout] 61 | | }
[INFO] [stdout]    | |_^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]   --> src/par_stream/take.rs:26:1
[INFO] [stdout]    |
[INFO] [stdout] 26 | / impl<S: ParallelStream> Take<S> {
[INFO] [stdout] 27 | |     pub(super) fn new(stream: S, remaining: usize) -> Self {
[INFO] [stdout] 28 | |         Self {
[INFO] [stdout] 29 | |             limit: stream.get_limit(),
[INFO] [stdout] ...  |
[INFO] [stdout] 33 | |     }
[INFO] [stdout] 34 | | }
[INFO] [stdout]    | |_^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]   --> src/par_stream/take.rs:27:5
[INFO] [stdout]    |
[INFO] [stdout] 27 | /     pub(super) fn new(stream: S, remaining: usize) -> Self {
[INFO] [stdout] 28 | |         Self {
[INFO] [stdout] 29 | |             limit: stream.get_limit(),
[INFO] [stdout] 30 | |             remaining,
[INFO] [stdout] 31 | |             stream,
[INFO] [stdout] 32 | |         }
[INFO] [stdout] 33 | |     }
[INFO] [stdout]    | |_____^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]   --> src/par_stream/mod.rs:18:1
[INFO] [stdout]    |
[INFO] [stdout] 18 | /// Parallel version of the standard `Stream` trait.
[INFO] [stdout]    | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]   --> src/par_stream/mod.rs:20:5
[INFO] [stdout]    |
[INFO] [stdout] 20 |     /// The type of items yielded by this stream.
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]   --> src/par_stream/mod.rs:23:5
[INFO] [stdout]    |
[INFO] [stdout] 23 |     /// Attempts to receive the next item from the stream.
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]   --> src/par_stream/mod.rs:26:5
[INFO] [stdout]    |
[INFO] [stdout] 26 |     /// Set a max concurrency limit
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]   --> src/par_stream/mod.rs:29:5
[INFO] [stdout]    |
[INFO] [stdout] 29 |     /// Get the max concurrency limit
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]   --> src/par_stream/mod.rs:32:5
[INFO] [stdout]    |
[INFO] [stdout] 32 | /     /// Applies `f` to each item of this stream in parallel, producing a new
[INFO] [stdout] 33 | |     /// stream with the results.
[INFO] [stdout]    | |________________________________^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]   --> src/par_stream/mod.rs:43:5
[INFO] [stdout]    |
[INFO] [stdout] 43 | /     /// Applies `f` to each item of this stream in parallel, producing a new
[INFO] [stdout] 44 | |     /// stream with the results.
[INFO] [stdout]    | |________________________________^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]   --> src/par_stream/mod.rs:49:5
[INFO] [stdout]    |
[INFO] [stdout] 49 |     /// Creates a stream that yields its first `n` elements.
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]   --> src/par_stream/mod.rs:57:5
[INFO] [stdout]    |
[INFO] [stdout] 57 |     /// Applies `f` to each item of this stream in parallel.
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]   --> src/par_stream/mod.rs:66:5
[INFO] [stdout]    |
[INFO] [stdout] 66 | /     /// Transforms a stream into a collection.
[INFO] [stdout] 67 | |     ///
[INFO] [stdout] 68 | |     ///`collect()` can take anything streamable, and turn it into a relevant
[INFO] [stdout] 69 | |     /// collection. This is one of the more powerful methods in the async
[INFO] [stdout] 70 | |     /// standard library, used in a variety of contexts.
[INFO] [stdout]    | |________________________________________________________^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]  --> src/prelude.rs:1:1
[INFO] [stdout]   |
[INFO] [stdout] 1 | //! The parallel stream prelude.
[INFO] [stdout]   | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]  --> src/vec.rs:1:1
[INFO] [stdout]   |
[INFO] [stdout] 1 | / //! Parallel types for `Vec`.
[INFO] [stdout] 2 | | //!
[INFO] [stdout] 3 | | //! You will rarely need to interact with this module directly unless you need to
[INFO] [stdout] 4 | | //! name one of the stream types.
[INFO] [stdout]   | |_________________________________^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]   --> src/utils.rs:55:6
[INFO] [stdout]    |
[INFO] [stdout] 55 | // }
[INFO] [stdout]    |      ^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]   --> src/vec.rs:71:5
[INFO] [stdout]    |
[INFO] [stdout] 71 | /     fn from_par_stream<'a, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'a + Send>>
[INFO] [stdout] 72 | |     where
[INFO] [stdout] 73 | |         S: IntoParallelStream<Item = T> + Send + 'a,
[INFO] [stdout] 74 | |     {
[INFO] [stdout] ...  |
[INFO] [stdout] 82 | |         })
[INFO] [stdout] 83 | |     }
[INFO] [stdout]    | |_____^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]   --> src/into_parallel_stream.rs:15:1
[INFO] [stdout]    |
[INFO] [stdout] 15 | / impl<I: ParallelStream> IntoParallelStream for I {
[INFO] [stdout] 16 | |     type Item = I::Item;
[INFO] [stdout] 17 | |     type IntoParStream = I;
[INFO] [stdout] 18 | |
[INFO] [stdout] ...  |
[INFO] [stdout] 22 | |     }
[INFO] [stdout] 23 | | }
[INFO] [stdout]    | |_^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]   --> src/into_parallel_stream.rs:16:5
[INFO] [stdout]    |
[INFO] [stdout] 16 |     type Item = I::Item;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]   --> src/into_parallel_stream.rs:17:5
[INFO] [stdout]    |
[INFO] [stdout] 17 |     type IntoParStream = I;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]   --> src/into_parallel_stream.rs:20:5
[INFO] [stdout]    |
[INFO] [stdout] 20 | /     fn into_par_stream(self) -> I {
[INFO] [stdout] 21 | |         self
[INFO] [stdout] 22 | |     }
[INFO] [stdout]    | |_____^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]   --> src/vec.rs:42:1
[INFO] [stdout]    |
[INFO] [stdout] 42 | / impl<T: Send + Sync + 'static> IntoParallelStream for Vec<T> {
[INFO] [stdout] 43 | |     type Item = T;
[INFO] [stdout] 44 | |     type IntoParStream = IntoParStream<T>;
[INFO] [stdout] 45 | |
[INFO] [stdout] ...  |
[INFO] [stdout] 52 | |     }
[INFO] [stdout] 53 | | }
[INFO] [stdout]    | |_^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]   --> src/vec.rs:43:5
[INFO] [stdout]    |
[INFO] [stdout] 43 |     type Item = T;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]   --> src/vec.rs:44:5
[INFO] [stdout]    |
[INFO] [stdout] 44 |     type IntoParStream = IntoParStream<T>;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]   --> src/vec.rs:47:5
[INFO] [stdout]    |
[INFO] [stdout] 47 | /     fn into_par_stream(self) -> Self::IntoParStream {
[INFO] [stdout] 48 | |         IntoParStream {
[INFO] [stdout] 49 | |             stream: from_stream(from_iter(self)),
[INFO] [stdout] 50 | |             limit: None,
[INFO] [stdout] 51 | |         }
[INFO] [stdout] 52 | |     }
[INFO] [stdout]    | |_____^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]   --> src/from_stream.rs:35:1
[INFO] [stdout]    |
[INFO] [stdout] 35 | / impl<S: Stream + Send + Sync + Unpin + 'static> ParallelStream for FromStream<S>
[INFO] [stdout] 36 | | where
[INFO] [stdout] 37 | |     S::Item: Send,
[INFO] [stdout] 38 | | {
[INFO] [stdout] ...  |
[INFO] [stdout] 53 | |     }
[INFO] [stdout] 54 | | }
[INFO] [stdout]    | |_^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]   --> src/from_stream.rs:39:5
[INFO] [stdout]    |
[INFO] [stdout] 39 |     type Item = S::Item;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]   --> src/from_stream.rs:41:5
[INFO] [stdout]    |
[INFO] [stdout] 41 | /     fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> {
[INFO] [stdout] 42 | |         let this = self.project();
[INFO] [stdout] 43 | |         this.stream.poll_next(cx)
[INFO] [stdout] 44 | |     }
[INFO] [stdout]    | |_____^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]   --> src/from_stream.rs:46:5
[INFO] [stdout]    |
[INFO] [stdout] 46 | /     fn limit(mut self, limit: impl Into<Option<usize>>) -> Self {
[INFO] [stdout] 47 | |         self.limit = limit.into();
[INFO] [stdout] 48 | |         self
[INFO] [stdout] 49 | |     }
[INFO] [stdout]    | |_____^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]   --> src/from_stream.rs:51:5
[INFO] [stdout]    |
[INFO] [stdout] 51 | /     fn get_limit(&self) -> Option<usize> {
[INFO] [stdout] 52 | |         self.limit
[INFO] [stdout] 53 | |     }
[INFO] [stdout]    | |_____^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]   --> src/par_stream/map.rs:44:1
[INFO] [stdout]    |
[INFO] [stdout] 44 | / impl<T: Send + 'static> ParallelStream for Map<T> {
[INFO] [stdout] 45 | |     type Item = T;
[INFO] [stdout] 46 | |     fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> {
[INFO] [stdout] 47 | |         use async_std::prelude::*;
[INFO] [stdout] ...  |
[INFO] [stdout] 59 | |     }
[INFO] [stdout] 60 | | }
[INFO] [stdout]    | |_^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]   --> src/par_stream/map.rs:45:5
[INFO] [stdout]    |
[INFO] [stdout] 45 |     type Item = T;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]   --> src/par_stream/map.rs:46:5
[INFO] [stdout]    |
[INFO] [stdout] 46 | /     fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> {
[INFO] [stdout] 47 | |         use async_std::prelude::*;
[INFO] [stdout] 48 | |         let this = self.project();
[INFO] [stdout] 49 | |         this.receiver.poll_next(cx)
[INFO] [stdout] 50 | |     }
[INFO] [stdout]    | |_____^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]   --> src/par_stream/map.rs:52:5
[INFO] [stdout]    |
[INFO] [stdout] 52 | /     fn limit(mut self, limit: impl Into<Option<usize>>) -> Self {
[INFO] [stdout] 53 | |         self.limit = limit.into();
[INFO] [stdout] 54 | |         self
[INFO] [stdout] 55 | |     }
[INFO] [stdout]    | |_____^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]   --> src/par_stream/map.rs:57:5
[INFO] [stdout]    |
[INFO] [stdout] 57 | /     fn get_limit(&self) -> Option<usize> {
[INFO] [stdout] 58 | |         self.limit
[INFO] [stdout] 59 | |     }
[INFO] [stdout]    | |_____^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]   --> src/par_stream/take.rs:36:1
[INFO] [stdout]    |
[INFO] [stdout] 36 | / impl<S: ParallelStream> ParallelStream for Take<S> {
[INFO] [stdout] 37 | |     type Item = S::Item;
[INFO] [stdout] 38 | |
[INFO] [stdout] 39 | |     fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<S::Item>> {
[INFO] [stdout] ...  |
[INFO] [stdout] 60 | |     }
[INFO] [stdout] 61 | | }
[INFO] [stdout]    | |_^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]   --> src/par_stream/take.rs:37:5
[INFO] [stdout]    |
[INFO] [stdout] 37 |     type Item = S::Item;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]   --> src/par_stream/take.rs:39:5
[INFO] [stdout]    |
[INFO] [stdout] 39 | /     fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<S::Item>> {
[INFO] [stdout] 40 | |         let this = self.project();
[INFO] [stdout] 41 | |         if *this.remaining == 0 {
[INFO] [stdout] 42 | |             Poll::Ready(None)
[INFO] [stdout] ...  |
[INFO] [stdout] 50 | |         }
[INFO] [stdout] 51 | |     }
[INFO] [stdout]    | |_____^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]   --> src/par_stream/take.rs:53:5
[INFO] [stdout]    |
[INFO] [stdout] 53 | /     fn limit(mut self, limit: impl Into<Option<usize>>) -> Self {
[INFO] [stdout] 54 | |         self.limit = limit.into();
[INFO] [stdout] 55 | |         self
[INFO] [stdout] 56 | |     }
[INFO] [stdout]    | |_____^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]   --> src/par_stream/take.rs:58:5
[INFO] [stdout]    |
[INFO] [stdout] 58 | /     fn get_limit(&self) -> Option<usize> {
[INFO] [stdout] 59 | |         self.limit
[INFO] [stdout] 60 | |     }
[INFO] [stdout]    | |_____^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]   --> src/vec.rs:25:1
[INFO] [stdout]    |
[INFO] [stdout] 25 | / impl<T: Send + Sync + 'static> ParallelStream for IntoParStream<T> {
[INFO] [stdout] 26 | |     type Item = T;
[INFO] [stdout] 27 | |     fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> {
[INFO] [stdout] 28 | |         let this = self.project();
[INFO] [stdout] ...  |
[INFO] [stdout] 39 | |     }
[INFO] [stdout] 40 | | }
[INFO] [stdout]    | |_^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]   --> src/vec.rs:26:5
[INFO] [stdout]    |
[INFO] [stdout] 26 |     type Item = T;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]   --> src/vec.rs:27:5
[INFO] [stdout]    |
[INFO] [stdout] 27 | /     fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> {
[INFO] [stdout] 28 | |         let this = self.project();
[INFO] [stdout] 29 | |         this.stream.poll_next(cx)
[INFO] [stdout] 30 | |     }
[INFO] [stdout]    | |_____^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]   --> src/vec.rs:32:5
[INFO] [stdout]    |
[INFO] [stdout] 32 | /     fn limit(mut self, limit: impl Into<Option<usize>>) -> Self {
[INFO] [stdout] 33 | |         self.limit = limit.into();
[INFO] [stdout] 34 | |         self
[INFO] [stdout] 35 | |     }
[INFO] [stdout]    | |_____^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]   --> src/vec.rs:37:5
[INFO] [stdout]    |
[INFO] [stdout] 37 | /     fn get_limit(&self) -> Option<usize> {
[INFO] [stdout] 38 | |         self.limit
[INFO] [stdout] 39 | |     }
[INFO] [stdout]    | |_____^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]   --> src/par_stream/for_each.rs:73:1
[INFO] [stdout]    |
[INFO] [stdout] 73 | / impl Future for ForEach {
[INFO] [stdout] 74 | |     type Output = ();
[INFO] [stdout] 75 | |
[INFO] [stdout] 76 | |     fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> {
[INFO] [stdout] ...  |
[INFO] [stdout] 80 | |     }
[INFO] [stdout] 81 | | }
[INFO] [stdout]    | |_^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]   --> src/par_stream/for_each.rs:74:5
[INFO] [stdout]    |
[INFO] [stdout] 74 |     type Output = ();
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: missing code example in this documentation
[INFO] [stdout]   --> src/par_stream/for_each.rs:76:5
[INFO] [stdout]    |
[INFO] [stdout] 76 | /     fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> {
[INFO] [stdout] 77 | |         let this = self.project();
[INFO] [stdout] 78 | |         task::ready!(this.receiver.poll_next(cx));
[INFO] [stdout] 79 | |         Poll::Ready(())
[INFO] [stdout] 80 | |     }
[INFO] [stdout]    | |_____^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: 71 warnings emitted
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stderr]     Finished dev [unoptimized + debuginfo] target(s) in 1m 02s
[INFO] running `Command { std: "docker" "inspect" "1e91cfa55748f9c8d75303d0406d54d4df3f33ef8c097141cbb71cd4f1b0d9de", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "1e91cfa55748f9c8d75303d0406d54d4df3f33ef8c097141cbb71cd4f1b0d9de", kill_on_drop: false }`
[INFO] [stdout] 1e91cfa55748f9c8d75303d0406d54d4df3f33ef8c097141cbb71cd4f1b0d9de