# rustc version rustc 1.43.0-nightly (1572c433e 2020-03-13)
# docs.rs version docsrs 0.6.0 (3ababaf 2020-03-14)
# build log [INFO] running `"docker" "create" "-v" "/home/cratesfyi/workspace/builds/parallel-stream-2.1.1/target:/opt/rustwide/target:rw,Z" "-v" "/home/cratesfyi/workspace/builds/parallel-stream-2.1.1/source:/opt/rustwide/workdir:ro,Z" "-v" "/home/cratesfyi/workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/home/cratesfyi/workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "MAP_USER_ID=1001" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "RUSTFLAGS=" "-e" "RUSTDOCFLAGS=-Z unstable-options --resource-suffix -20200313-1.43.0-nightly-1572c433e --static-root-path / --extern-html-root-url async_std=https://docs.rs/async-std/1.5.0 --extern-html-root-url pin_project_lite=https://docs.rs/pin-project-lite/0.1.4" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "3221225472" "--network" "none" "rustops/crates-build-env" "/opt/rustwide/cargo-home/bin/cargo" "+nightly" "doc" "--lib" "--no-deps"` [INFO] [stderr] WARNING: Your kernel does not support swap limit capabilities or the cgroup is not mounted. Memory limited without swap. [INFO] [stdout] a3c6c4aa23cc15801de344c11d502c30a38a970d3d74a63a8affff73a4cad2db [INFO] running `"docker" "start" "-a" "a3c6c4aa23cc15801de344c11d502c30a38a970d3d74a63a8affff73a4cad2db"` [INFO] [stderr] Checking cfg-if v0.1.10 [INFO] [stderr] Compiling libc v0.2.67 [INFO] [stderr] Compiling proc-macro2 v1.0.9 [INFO] [stderr] Compiling autocfg v1.0.0 [INFO] [stderr] Compiling unicode-xid v0.2.0 [INFO] [stderr] Compiling semver-parser v0.7.0 [INFO] [stderr] Compiling syn v1.0.16 [INFO] [stderr] Compiling log v0.4.8 [INFO] [stderr] Checking scopeguard v1.1.0 [INFO] [stderr] Compiling maybe-uninit v2.0.0 [INFO] [stderr] Compiling proc-macro-nested v0.1.3 [INFO] [stderr] Checking lazy_static v1.4.0 [INFO] [stderr] Checking slab v0.4.2 [INFO] [stderr] Checking futures-core v0.3.4 [INFO] [stderr] Checking smallvec v1.2.0 [INFO] [stderr] Checking futures-sink v0.3.4 [INFO] [stderr] Checking futures-task v0.3.4 [INFO] [stderr] Compiling memchr v2.3.3 [INFO] [stderr] Checking pin-utils v0.1.0-alpha.4 [INFO] [stderr] Checking pin-project-lite v0.1.4 [INFO] [stderr] Checking futures-timer v2.0.2 [INFO] [stderr] Checking futures-io v0.3.4 [INFO] [stderr] Checking once_cell v1.3.1 [INFO] [stderr] Compiling semver v0.9.0 [INFO] [stderr] Compiling crossbeam-utils v0.7.2 [INFO] [stderr] Compiling crossbeam-epoch v0.8.2 [INFO] [stderr] Checking lock_api v0.3.3 [INFO] [stderr] Checking futures-channel v0.3.4 [INFO] [stderr] Compiling rustc_version v0.2.3 [INFO] [stderr] Checking kv-log-macro v1.0.4 [INFO] [stderr] Compiling quote v1.0.3 [INFO] [stderr] Checking parking_lot_core v0.7.0 [INFO] [stderr] Checking iovec v0.1.4 [INFO] [stderr] Checking net2 v0.2.33 [INFO] [stderr] Checking num_cpus v1.12.0 [INFO] [stderr] Checking async-task v1.3.1 [INFO] [stderr] Compiling memoffset v0.5.3 [INFO] [stderr] Checking crossbeam-channel v0.4.2 [INFO] [stderr] Checking parking_lot v0.10.0 [INFO] [stderr] Checking mio v0.6.21 [INFO] [stderr] Checking crossbeam-deque v0.7.3 [INFO] [stderr] Checking mio-uds v0.6.7 [INFO] [stderr] Compiling proc-macro-hack v0.5.11 [INFO] [stderr] Compiling async-attributes v1.1.1 [INFO] [stderr] Compiling futures-macro v0.3.4 [INFO] [stderr] Checking futures-util v0.3.4 [INFO] [stderr] Checking broadcaster v1.0.0 [INFO] [stderr] Checking async-std v1.5.0 [INFO] [stderr] Documenting parallel-stream v2.1.1 (/opt/rustwide/workdir) [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/from_stream.rs:24:1 [INFO] [stderr] | [INFO] [stderr] 24 | /// Converts a stream into a parallel stream. [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] | [INFO] [stderr] note: the lint level is defined here [INFO] [stderr] --> src/lib.rs:45:23 [INFO] [stderr] | [INFO] [stderr] 45 | #![warn(missing_docs, missing_doc_code_examples)] [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/from_parallel_stream.rs:1:1 [INFO] [stderr] | [INFO] [stderr] 1 | / use core::future::Future; [INFO] [stderr] 2 | | use core::pin::Pin; [INFO] [stderr] 3 | | [INFO] [stderr] 4 | | use crate::IntoParallelStream; [INFO] [stderr] ... | [INFO] [stderr] 24 | | .await; [INFO] [stderr] 25 | | } [INFO] [stderr] | |_^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/from_parallel_stream.rs:6:1 [INFO] [stderr] | [INFO] [stderr] 6 | /// Conversion from a `ParallelStream`. [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/from_parallel_stream.rs:8:5 [INFO] [stderr] | [INFO] [stderr] 8 | /// Creates a value from a stream. [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/from_stream.rs:1:1 [INFO] [stderr] | [INFO] [stderr] 1 | / use core::pin::Pin; [INFO] [stderr] 2 | | [INFO] [stderr] 3 | | use async_std::stream::{IntoStream, Stream}; [INFO] [stderr] 4 | | use async_std::task::{Context, Poll}; [INFO] [stderr] ... | [INFO] [stderr] 53 | | } [INFO] [stderr] 54 | | } [INFO] [stderr] | |_^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/from_stream.rs:24:1 [INFO] [stderr] | [INFO] [stderr] 24 | /// Converts a stream into a parallel stream. [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/into_parallel_stream.rs:1:1 [INFO] [stderr] | [INFO] [stderr] 1 | / use crate::ParallelStream; [INFO] [stderr] 2 | | [INFO] [stderr] 3 | | /// Conversion into a `ParallelStream`. [INFO] [stderr] 4 | | pub trait IntoParallelStream { [INFO] [stderr] ... | [INFO] [stderr] 22 | | } [INFO] [stderr] 23 | | } [INFO] [stderr] | |_^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/into_parallel_stream.rs:3:1 [INFO] [stderr] | [INFO] [stderr] 3 | /// Conversion into a `ParallelStream`. [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/into_parallel_stream.rs:5:5 [INFO] [stderr] | [INFO] [stderr] 5 | /// The type of the elements being iterated over. [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/into_parallel_stream.rs:8:5 [INFO] [stderr] | [INFO] [stderr] 8 | /// Which kind of stream are we turning this into? [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/into_parallel_stream.rs:11:5 [INFO] [stderr] | [INFO] [stderr] 11 | /// Creates a parallel stream from a value. [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/par_stream/mod.rs:1:1 [INFO] [stderr] | [INFO] [stderr] 1 | / use async_std::future::Future; [INFO] [stderr] 2 | | use async_std::task::{Context, Poll}; [INFO] [stderr] 3 | | [INFO] [stderr] 4 | | use std::pin::Pin; [INFO] [stderr] ... | [INFO] [stderr] 77 | | } [INFO] [stderr] 78 | | } [INFO] [stderr] | |_^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/par_stream/mod.rs:8:1 [INFO] [stderr] | [INFO] [stderr] 8 | pub use for_each::ForEach; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/par_stream/mod.rs:9:1 [INFO] [stderr] | [INFO] [stderr] 9 | pub use map::Map; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/par_stream/mod.rs:10:1 [INFO] [stderr] | [INFO] [stderr] 10 | pub use next::NextFuture; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/par_stream/mod.rs:11:1 [INFO] [stderr] | [INFO] [stderr] 11 | pub use take::Take; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/par_stream/for_each.rs:1:1 [INFO] [stderr] | [INFO] [stderr] 1 | / use async_std::prelude::*; [INFO] [stderr] 2 | | use async_std::sync::{self, Receiver, Sender}; [INFO] [stderr] 3 | | use async_std::task::{self, Context, Poll}; [INFO] [stderr] 4 | | [INFO] [stderr] ... | [INFO] [stderr] 92 | | .await; [INFO] [stderr] 93 | | } [INFO] [stderr] | |_^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/par_stream/for_each.rs:25:1 [INFO] [stderr] | [INFO] [stderr] 25 | / impl ForEach { [INFO] [stderr] 26 | | /// Create a new instance of `ForEach`. [INFO] [stderr] 27 | | pub fn new<S, F, Fut>(mut stream: S, mut f: F) -> Self [INFO] [stderr] 28 | | where [INFO] [stderr] ... | [INFO] [stderr] 70 | | } [INFO] [stderr] 71 | | } [INFO] [stderr] | |_^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/par_stream/for_each.rs:26:5 [INFO] [stderr] | [INFO] [stderr] 26 | /// Create a new instance of `ForEach`. [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/par_stream/map.rs:2:1 [INFO] [stderr] | [INFO] [stderr] 2 | / use async_std::future::Future; [INFO] [stderr] 3 | | use async_std::sync::{self, Receiver}; [INFO] [stderr] 4 | | use async_std::task; [INFO] [stderr] 5 | | [INFO] [stderr] ... | [INFO] [stderr] 71 | | assert_eq!(output, vec![10usize; 3]); [INFO] [stderr] 72 | | } [INFO] [stderr] | |_^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/par_stream/map.rs:21:1 [INFO] [stderr] | [INFO] [stderr] 21 | / impl<T: Send + 'static> Map<T> { [INFO] [stderr] 22 | | /// Create a new instance of `Map`. [INFO] [stderr] 23 | | pub fn new<S, F, Fut>(mut stream: S, mut f: F) -> Self [INFO] [stderr] 24 | | where [INFO] [stderr] ... | [INFO] [stderr] 41 | | } [INFO] [stderr] 42 | | } [INFO] [stderr] | |_^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/par_stream/map.rs:22:5 [INFO] [stderr] | [INFO] [stderr] 22 | /// Create a new instance of `Map`. [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/par_stream/next.rs:1:1 [INFO] [stderr] | [INFO] [stderr] 1 | / use core::future::Future; [INFO] [stderr] 2 | | use core::pin::Pin; [INFO] [stderr] 3 | | use core::task::{Context, Poll}; [INFO] [stderr] 4 | | [INFO] [stderr] ... | [INFO] [stderr] 24 | | } [INFO] [stderr] 25 | | } [INFO] [stderr] | |_^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/par_stream/take.rs:1:1 [INFO] [stderr] | [INFO] [stderr] 1 | / use core::pin::Pin; [INFO] [stderr] 2 | | use core::task::{Context, Poll}; [INFO] [stderr] 3 | | [INFO] [stderr] 4 | | use async_std::task::ready; [INFO] [stderr] ... | [INFO] [stderr] 60 | | } [INFO] [stderr] 61 | | } [INFO] [stderr] | |_^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/par_stream/mod.rs:18:1 [INFO] [stderr] | [INFO] [stderr] 18 | /// Parallel version of the standard `Stream` trait. [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/par_stream/mod.rs:20:5 [INFO] [stderr] | [INFO] [stderr] 20 | /// The type of items yielded by this stream. [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/par_stream/mod.rs:23:5 [INFO] [stderr] | [INFO] [stderr] 23 | /// Attempts to receive the next item from the stream. [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/par_stream/mod.rs:26:5 [INFO] [stderr] | [INFO] [stderr] 26 | /// Set a max concurrency limit [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/par_stream/mod.rs:29:5 [INFO] [stderr] | [INFO] [stderr] 29 | /// Get the max concurrency limit [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/par_stream/mod.rs:32:5 [INFO] [stderr] | [INFO] [stderr] 32 | / /// Applies `f` to each item of this stream in parallel, producing a new [INFO] [stderr] 33 | | /// stream with the results. [INFO] [stderr] | |________________________________^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/par_stream/mod.rs:43:5 [INFO] [stderr] | [INFO] [stderr] 43 | / /// Applies `f` to each item of this stream in parallel, producing a new [INFO] [stderr] 44 | | /// stream with the results. [INFO] [stderr] | |________________________________^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/par_stream/mod.rs:49:5 [INFO] [stderr] | [INFO] [stderr] 49 | /// Creates a stream that yields its first `n` elements. [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/par_stream/mod.rs:57:5 [INFO] [stderr] | [INFO] [stderr] 57 | /// Applies `f` to each item of this stream in parallel. [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/par_stream/mod.rs:66:5 [INFO] [stderr] | [INFO] [stderr] 66 | / /// Transforms a stream into a collection. [INFO] [stderr] 67 | | /// [INFO] [stderr] 68 | | ///`collect()` can take anything streamable, and turn it into a relevant [INFO] [stderr] 69 | | /// collection. This is one of the more powerful methods in the async [INFO] [stderr] 70 | | /// standard library, used in a variety of contexts. [INFO] [stderr] | |________________________________________________________^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/prelude.rs:1:1 [INFO] [stderr] | [INFO] [stderr] 1 | //! The parallel stream prelude. [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/vec.rs:1:1 [INFO] [stderr] | [INFO] [stderr] 1 | / //! Parallel types for `Vec`. [INFO] [stderr] 2 | | //! [INFO] [stderr] 3 | | //! You will rarely need to interact with this module directly unless you need to [INFO] [stderr] 4 | | //! name one of the stream types. [INFO] [stderr] | |_________________________________^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/utils.rs:55:6 [INFO] [stderr] | [INFO] [stderr] 55 | // } [INFO] [stderr] | ^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/vec.rs:71:5 [INFO] [stderr] | [INFO] [stderr] 71 | / fn from_par_stream<'a, S>(stream: S) -> Pin<Box<dyn Future<Output = Self> + 'a + Send>> [INFO] [stderr] 72 | | where [INFO] [stderr] 73 | | S: IntoParallelStream<Item = T> + Send + 'a, [INFO] [stderr] 74 | | { [INFO] [stderr] ... | [INFO] [stderr] 82 | | }) [INFO] [stderr] 83 | | } [INFO] [stderr] | |_____^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/into_parallel_stream.rs:15:1 [INFO] [stderr] | [INFO] [stderr] 15 | / impl<I: ParallelStream> IntoParallelStream for I { [INFO] [stderr] 16 | | type Item = I::Item; [INFO] [stderr] 17 | | type IntoParStream = I; [INFO] [stderr] 18 | | [INFO] [stderr] ... | [INFO] [stderr] 22 | | } [INFO] [stderr] 23 | | } [INFO] [stderr] | |_^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/into_parallel_stream.rs:16:5 [INFO] [stderr] | [INFO] [stderr] 16 | type Item = I::Item; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/into_parallel_stream.rs:17:5 [INFO] [stderr] | [INFO] [stderr] 17 | type IntoParStream = I; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/into_parallel_stream.rs:20:5 [INFO] [stderr] | [INFO] [stderr] 20 | / fn into_par_stream(self) -> I { [INFO] [stderr] 21 | | self [INFO] [stderr] 22 | | } [INFO] [stderr] | |_____^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/vec.rs:42:1 [INFO] [stderr] | [INFO] [stderr] 42 | / impl<T: Send + Sync + 'static> IntoParallelStream for Vec<T> { [INFO] [stderr] 43 | | type Item = T; [INFO] [stderr] 44 | | type IntoParStream = IntoParStream<T>; [INFO] [stderr] 45 | | [INFO] [stderr] ... | [INFO] [stderr] 52 | | } [INFO] [stderr] 53 | | } [INFO] [stderr] | |_^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/vec.rs:43:5 [INFO] [stderr] | [INFO] [stderr] 43 | type Item = T; [INFO] [stderr] | ^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/vec.rs:44:5 [INFO] [stderr] | [INFO] [stderr] 44 | type IntoParStream = IntoParStream<T>; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/vec.rs:47:5 [INFO] [stderr] | [INFO] [stderr] 47 | / fn into_par_stream(self) -> Self::IntoParStream { [INFO] [stderr] 48 | | IntoParStream { [INFO] [stderr] 49 | | stream: from_stream(from_iter(self)), [INFO] [stderr] 50 | | limit: None, [INFO] [stderr] 51 | | } [INFO] [stderr] 52 | | } [INFO] [stderr] | |_____^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/from_stream.rs:35:1 [INFO] [stderr] | [INFO] [stderr] 35 | / impl<S: Stream + Send + Sync + Unpin + 'static> ParallelStream for FromStream<S> [INFO] [stderr] 36 | | where [INFO] [stderr] 37 | | S::Item: Send, [INFO] [stderr] 38 | | { [INFO] [stderr] ... | [INFO] [stderr] 53 | | } [INFO] [stderr] 54 | | } [INFO] [stderr] | |_^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/from_stream.rs:39:5 [INFO] [stderr] | [INFO] [stderr] 39 | type Item = S::Item; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/from_stream.rs:41:5 [INFO] [stderr] | [INFO] [stderr] 41 | / fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> { [INFO] [stderr] 42 | | let this = self.project(); [INFO] [stderr] 43 | | this.stream.poll_next(cx) [INFO] [stderr] 44 | | } [INFO] [stderr] | |_____^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/from_stream.rs:46:5 [INFO] [stderr] | [INFO] [stderr] 46 | / fn limit(mut self, limit: impl Into<Option<usize>>) -> Self { [INFO] [stderr] 47 | | self.limit = limit.into(); [INFO] [stderr] 48 | | self [INFO] [stderr] 49 | | } [INFO] [stderr] | |_____^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/from_stream.rs:51:5 [INFO] [stderr] | [INFO] [stderr] 51 | / fn get_limit(&self) -> Option<usize> { [INFO] [stderr] 52 | | self.limit [INFO] [stderr] 53 | | } [INFO] [stderr] | |_____^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/par_stream/map.rs:44:1 [INFO] [stderr] | [INFO] [stderr] 44 | / impl<T: Send + 'static> ParallelStream for Map<T> { [INFO] [stderr] 45 | | type Item = T; [INFO] [stderr] 46 | | fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> { [INFO] [stderr] 47 | | use async_std::prelude::*; [INFO] [stderr] ... | [INFO] [stderr] 59 | | } [INFO] [stderr] 60 | | } [INFO] [stderr] | |_^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/par_stream/map.rs:45:5 [INFO] [stderr] | [INFO] [stderr] 45 | type Item = T; [INFO] [stderr] | ^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/par_stream/map.rs:46:5 [INFO] [stderr] | [INFO] [stderr] 46 | / fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> { [INFO] [stderr] 47 | | use async_std::prelude::*; [INFO] [stderr] 48 | | let this = self.project(); [INFO] [stderr] 49 | | this.receiver.poll_next(cx) [INFO] [stderr] 50 | | } [INFO] [stderr] | |_____^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/par_stream/map.rs:52:5 [INFO] [stderr] | [INFO] [stderr] 52 | / fn limit(mut self, limit: impl Into<Option<usize>>) -> Self { [INFO] [stderr] 53 | | self.limit = limit.into(); [INFO] [stderr] 54 | | self [INFO] [stderr] 55 | | } [INFO] [stderr] | |_____^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/par_stream/map.rs:57:5 [INFO] [stderr] | [INFO] [stderr] 57 | / fn get_limit(&self) -> Option<usize> { [INFO] [stderr] 58 | | self.limit [INFO] [stderr] 59 | | } [INFO] [stderr] | |_____^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/par_stream/take.rs:36:1 [INFO] [stderr] | [INFO] [stderr] 36 | / impl<S: ParallelStream> ParallelStream for Take<S> { [INFO] [stderr] 37 | | type Item = S::Item; [INFO] [stderr] 38 | | [INFO] [stderr] 39 | | fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<S::Item>> { [INFO] [stderr] ... | [INFO] [stderr] 60 | | } [INFO] [stderr] 61 | | } [INFO] [stderr] | |_^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/par_stream/take.rs:37:5 [INFO] [stderr] | [INFO] [stderr] 37 | type Item = S::Item; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/par_stream/take.rs:39:5 [INFO] [stderr] | [INFO] [stderr] 39 | / fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<S::Item>> { [INFO] [stderr] 40 | | let this = self.project(); [INFO] [stderr] 41 | | if *this.remaining == 0 { [INFO] [stderr] 42 | | Poll::Ready(None) [INFO] [stderr] ... | [INFO] [stderr] 50 | | } [INFO] [stderr] 51 | | } [INFO] [stderr] | |_____^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/par_stream/take.rs:53:5 [INFO] [stderr] | [INFO] [stderr] 53 | / fn limit(mut self, limit: impl Into<Option<usize>>) -> Self { [INFO] [stderr] 54 | | self.limit = limit.into(); [INFO] [stderr] 55 | | self [INFO] [stderr] 56 | | } [INFO] [stderr] | |_____^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/par_stream/take.rs:58:5 [INFO] [stderr] | [INFO] [stderr] 58 | / fn get_limit(&self) -> Option<usize> { [INFO] [stderr] 59 | | self.limit [INFO] [stderr] 60 | | } [INFO] [stderr] | |_____^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/vec.rs:25:1 [INFO] [stderr] | [INFO] [stderr] 25 | / impl<T: Send + Sync + 'static> ParallelStream for IntoParStream<T> { [INFO] [stderr] 26 | | type Item = T; [INFO] [stderr] 27 | | fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> { [INFO] [stderr] 28 | | let this = self.project(); [INFO] [stderr] ... | [INFO] [stderr] 39 | | } [INFO] [stderr] 40 | | } [INFO] [stderr] | |_^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/vec.rs:26:5 [INFO] [stderr] | [INFO] [stderr] 26 | type Item = T; [INFO] [stderr] | ^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/vec.rs:27:5 [INFO] [stderr] | [INFO] [stderr] 27 | / fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> { [INFO] [stderr] 28 | | let this = self.project(); [INFO] [stderr] 29 | | this.stream.poll_next(cx) [INFO] [stderr] 30 | | } [INFO] [stderr] | |_____^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/vec.rs:32:5 [INFO] [stderr] | [INFO] [stderr] 32 | / fn limit(mut self, limit: impl Into<Option<usize>>) -> Self { [INFO] [stderr] 33 | | self.limit = limit.into(); [INFO] [stderr] 34 | | self [INFO] [stderr] 35 | | } [INFO] [stderr] | |_____^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/vec.rs:37:5 [INFO] [stderr] | [INFO] [stderr] 37 | / fn get_limit(&self) -> Option<usize> { [INFO] [stderr] 38 | | self.limit [INFO] [stderr] 39 | | } [INFO] [stderr] | |_____^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/par_stream/for_each.rs:73:1 [INFO] [stderr] | [INFO] [stderr] 73 | / impl Future for ForEach { [INFO] [stderr] 74 | | type Output = (); [INFO] [stderr] 75 | | [INFO] [stderr] 76 | | fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { [INFO] [stderr] ... | [INFO] [stderr] 80 | | } [INFO] [stderr] 81 | | } [INFO] [stderr] | |_^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/par_stream/for_each.rs:74:5 [INFO] [stderr] | [INFO] [stderr] 74 | type Output = (); [INFO] [stderr] | ^^^^^^^^^^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: missing code example in this documentation [INFO] [stderr] --> src/par_stream/for_each.rs:76:5 [INFO] [stderr] | [INFO] [stderr] 76 | / fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { [INFO] [stderr] 77 | | let this = self.project(); [INFO] [stderr] 78 | | task::ready!(this.receiver.poll_next(cx)); [INFO] [stderr] 79 | | Poll::Ready(()) [INFO] [stderr] 80 | | } [INFO] [stderr] | |_____^ [INFO] [stderr] [INFO] [stderr] warning: doc comment contains an invalid Rust code block [INFO] [stderr] | [INFO] [stderr] = help: mark blocks that do not contain Rust code as text: ```text [INFO] [stderr] [INFO] [stderr] Finished dev [unoptimized + debuginfo] target(s) in 29.68s [INFO] running `"docker" "inspect" "a3c6c4aa23cc15801de344c11d502c30a38a970d3d74a63a8affff73a4cad2db"` [INFO] running `"docker" "rm" "-f" "a3c6c4aa23cc15801de344c11d502c30a38a970d3d74a63a8affff73a4cad2db"` [INFO] [stdout] a3c6c4aa23cc15801de344c11d502c30a38a970d3d74a63a8affff73a4cad2db