Build #305143 2020-10-17 16:53:18
# rustc version
rustc 1.49.0-nightly (e3051d8c2 2020-10-16)# docs.rs version
docsrs 0.6.0 (0bbe2ff 2020-10-14)# build log
[INFO] running `Command { std: "docker" "create" "-v" "/home/cratesfyi/workspace/builds/parallel-stream-2.1.2/target:/opt/rustwide/target:rw,Z" "-v" "/home/cratesfyi/workspace/builds/parallel-stream-2.1.2/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" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "DOCS_RS=1" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "3221225472" "--cpus" "2" "--user" "1001:1001" "--network" "none" "rustops/crates-build-env@sha256:d92eaeed33fa75130ca1ee6c8a01d1ffb62bac859dfdfb3450e3e5d1c0146529" "/opt/rustwide/cargo-home/bin/cargo" "+nightly" "rustdoc" "--lib" "-j2" "--" "-Z" "unstable-options" "--extern-html-root-url" "async_std=https://docs.rs/async-std/1.6.5" "--extern-html-root-url" "pin_project_lite=https://docs.rs/pin-project-lite/0.1.10" "--resource-suffix" "-20201016-1.49.0-nightly-e3051d8c2" "--static-root-path" "/" "--cap-lints" "warn" "--disable-per-crate-search", kill_on_drop: false }`
[INFO] [stdout] 2c133a0bd01afa64fd3f8377ff726b79e8cf726dded7ccf0b0dd56a5732bd2ad
[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" "2c133a0bd01afa64fd3f8377ff726b79e8cf726dded7ccf0b0dd56a5732bd2ad", kill_on_drop: false }`
[INFO] [stderr] /opt/crates-build-env/entrypoint.sh: line 7: /etc/hosts: Permission denied
[INFO] [stderr] Compiling libc v0.2.79
[INFO] [stderr] Compiling memchr v2.3.3
[INFO] [stderr] Checking cfg-if v0.1.10
[INFO] [stderr] Checking cache-padded v1.1.1
[INFO] [stderr] Compiling log v0.4.11
[INFO] [stderr] Checking futures-core v0.3.6
[INFO] [stderr] Checking futures-io v0.3.6
[INFO] [stderr] Checking waker-fn v1.1.0
[INFO] [stderr] Checking pin-project-lite v0.1.10
[INFO] [stderr] Checking fastrand v1.4.0
[INFO] [stderr] Compiling proc-macro2 v1.0.24
[INFO] [stderr] Checking parking v2.0.0
[INFO] [stderr] Checking once_cell v1.4.1
[INFO] [stderr] Compiling unicode-xid v0.2.1
[INFO] [stderr] Checking vec-arena v1.0.0
[INFO] [stderr] Checking async-task v4.0.2
[INFO] [stderr] Compiling autocfg v1.0.1
[INFO] [stderr] Compiling syn v1.0.44
[INFO] [stderr] Checking event-listener v2.5.1
[INFO] [stderr] Checking atomic-waker v1.0.0
[INFO] [stderr] Checking lazy_static v1.4.0
[INFO] [stderr] Checking slab v0.4.2
[INFO] [stderr] Checking pin-utils v0.1.0
[INFO] [stderr] Checking concurrent-queue v1.2.2
[INFO] [stderr] Checking async-mutex v1.4.0
[INFO] [stderr] Compiling crossbeam-utils v0.7.2
[INFO] [stderr] Checking async-channel v1.5.1
[INFO] [stderr] Checking futures-lite v1.11.1
[INFO] [stderr] Checking kv-log-macro v1.0.7
[INFO] [stderr] Checking nb-connect v1.0.2
[INFO] [stderr] Checking polling v2.0.1
[INFO] [stderr] Checking num_cpus v1.13.0
[INFO] [stderr] Compiling quote v1.0.7
[INFO] [stderr] Checking async-io v1.1.10
[INFO] [stderr] Checking async-executor v1.3.0
[INFO] [stderr] Checking blocking v1.0.2
[INFO] [stderr] Checking async-global-executor v1.4.0
[INFO] [stderr] Compiling async-attributes v1.1.1
[INFO] [stderr] Checking async-std v1.6.5
[INFO] [stderr] Documenting parallel-stream v2.1.2 (/opt/rustwide/workdir)
[INFO] [stderr] warning: missing code example in this documentation
[INFO] [stderr] --> src/par_stream/next.rs:9:1
[INFO] [stderr] |
[INFO] [stderr] 9 | / pub struct NextFuture<'a, S: Unpin + ?Sized> {
[INFO] [stderr] 10 | | stream: &'a mut S,
[INFO] [stderr] 11 | | }
[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_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/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/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: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/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/next.rs:9:1
[INFO] [stderr] |
[INFO] [stderr] 9 | / pub struct NextFuture<'a, S: Unpin + ?Sized> {
[INFO] [stderr] 10 | | stream: &'a mut S,
[INFO] [stderr] 11 | | }
[INFO] [stderr] | |_^
[INFO] [stderr]
[INFO] [stderr] warning: missing code example in this documentation
[INFO] [stderr] --> src/par_stream/next.rs:13:1
[INFO] [stderr] |
[INFO] [stderr] 13 | / impl<'a, S: ParallelStream + Unpin + ?Sized> NextFuture<'a, S> {
[INFO] [stderr] 14 | | pub(crate) fn new(stream: &'a mut S) -> Self {
[INFO] [stderr] 15 | | Self { stream }
[INFO] [stderr] 16 | | }
[INFO] [stderr] 17 | | }
[INFO] [stderr] | |_^
[INFO] [stderr]
[INFO] [stderr] warning: missing code example in this documentation
[INFO] [stderr] --> src/par_stream/next.rs:14:5
[INFO] [stderr] |
[INFO] [stderr] 14 | / pub(crate) fn new(stream: &'a mut S) -> Self {
[INFO] [stderr] 15 | | Self { stream }
[INFO] [stderr] 16 | | }
[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/take.rs:26:1
[INFO] [stderr] |
[INFO] [stderr] 26 | / impl<S: ParallelStream> Take<S> {
[INFO] [stderr] 27 | | pub(super) fn new(stream: S, remaining: usize) -> Self {
[INFO] [stderr] 28 | | Self {
[INFO] [stderr] 29 | | limit: stream.get_limit(),
[INFO] [stderr] ... |
[INFO] [stderr] 33 | | }
[INFO] [stderr] 34 | | }
[INFO] [stderr] | |_^
[INFO] [stderr]
[INFO] [stderr] warning: missing code example in this documentation
[INFO] [stderr] --> src/par_stream/take.rs:27:5
[INFO] [stderr] |
[INFO] [stderr] 27 | / pub(super) fn new(stream: S, remaining: usize) -> Self {
[INFO] [stderr] 28 | | Self {
[INFO] [stderr] 29 | | limit: stream.get_limit(),
[INFO] [stderr] 30 | | remaining,
[INFO] [stderr] 31 | | stream,
[INFO] [stderr] 32 | | }
[INFO] [stderr] 33 | | }
[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: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: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: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: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: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: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: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: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: missing code example in this documentation
[INFO] [stderr] --> src/par_stream/next.rs:19:1
[INFO] [stderr] |
[INFO] [stderr] 19 | / impl<S: ParallelStream + Unpin + ?Sized> Future for NextFuture<'_, S> {
[INFO] [stderr] 20 | | type Output = Option<S::Item>;
[INFO] [stderr] 21 | |
[INFO] [stderr] 22 | | fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> {
[INFO] [stderr] 23 | | Pin::new(&mut *self.stream).poll_next(cx)
[INFO] [stderr] 24 | | }
[INFO] [stderr] 25 | | }
[INFO] [stderr] | |_^
[INFO] [stderr]
[INFO] [stderr] warning: missing code example in this documentation
[INFO] [stderr] --> src/par_stream/next.rs:22:5
[INFO] [stderr] |
[INFO] [stderr] 22 | / fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> {
[INFO] [stderr] 23 | | Pin::new(&mut *self.stream).poll_next(cx)
[INFO] [stderr] 24 | | }
[INFO] [stderr] | |_____^
[INFO] [stderr]
[INFO] [stderr] warning: 60 warnings emitted
[INFO] [stderr]
[INFO] [stderr] Finished dev [unoptimized + debuginfo] target(s) in 28.40s
[INFO] running `Command { std: "docker" "inspect" "2c133a0bd01afa64fd3f8377ff726b79e8cf726dded7ccf0b0dd56a5732bd2ad", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "2c133a0bd01afa64fd3f8377ff726b79e8cf726dded7ccf0b0dd56a5732bd2ad", kill_on_drop: false }`
[INFO] [stdout] 2c133a0bd01afa64fd3f8377ff726b79e8cf726dded7ccf0b0dd56a5732bd2ad