[INFO] fetching crate tsyncp 0.3.0... [INFO] documenting tsyncp-0.3.0 against beta-2022-05-20 for beta-1.62-rustdoc-1 [INFO] extracting crate tsyncp 0.3.0 into /workspace/builds/worker-37/source [INFO] validating manifest of crates.io crate tsyncp 0.3.0 on toolchain beta-2022-05-20 [INFO] running `Command { std: "/workspace/cargo-home/bin/cargo" "+beta-2022-05-20" "metadata" "--manifest-path" "Cargo.toml" "--no-deps", kill_on_drop: false }` [INFO] started tweaking crates.io crate tsyncp 0.3.0 [INFO] finished tweaking crates.io crate tsyncp 0.3.0 [INFO] tweaked toml for crates.io crate tsyncp 0.3.0 written to /workspace/builds/worker-37/source/Cargo.toml [INFO] crate crates.io crate tsyncp 0.3.0 already has a lockfile, it will not be regenerated [INFO] running `Command { std: "/workspace/cargo-home/bin/cargo" "+beta-2022-05-20" "fetch" "--manifest-path" "Cargo.toml", kill_on_drop: false }` [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-37/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-37/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" "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" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:d190cb871061d98bc6d0581d85cb2ecb09a0f8a142ba5463de30be9999fc3251" "/opt/rustwide/cargo-home/bin/cargo" "+beta-2022-05-20" "metadata" "--no-deps" "--format-version=1", kill_on_drop: false }` [INFO] [stdout] 0be742bc185547f1cbc44c0551800be1df8b783dc1565d57b30841355dd15111 [INFO] running `Command { std: "docker" "start" "-a" "0be742bc185547f1cbc44c0551800be1df8b783dc1565d57b30841355dd15111", kill_on_drop: false }` [INFO] running `Command { std: "docker" "inspect" "0be742bc185547f1cbc44c0551800be1df8b783dc1565d57b30841355dd15111", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "0be742bc185547f1cbc44c0551800be1df8b783dc1565d57b30841355dd15111", kill_on_drop: false }` [INFO] [stdout] 0be742bc185547f1cbc44c0551800be1df8b783dc1565d57b30841355dd15111 [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-37/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-37/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" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTDOCFLAGS=--cap-lints=warn" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:d190cb871061d98bc6d0581d85cb2ecb09a0f8a142ba5463de30be9999fc3251" "/opt/rustwide/cargo-home/bin/cargo" "+beta-2022-05-20" "doc" "--frozen" "--no-deps" "--document-private-items" "--message-format=json", kill_on_drop: false }` [INFO] [stdout] 652093a694dde6f4740dc857b7f0e777b15b19c38832b3cbdc917476667deb35 [INFO] running `Command { std: "docker" "start" "-a" "652093a694dde6f4740dc857b7f0e777b15b19c38832b3cbdc917476667deb35", kill_on_drop: false }` [INFO] [stderr] Compiling proc-macro2 v1.0.37 [INFO] [stderr] Compiling unicode-xid v0.2.2 [INFO] [stderr] Compiling syn v1.0.91 [INFO] [stderr] Checking cfg-if v1.0.0 [INFO] [stderr] Compiling libc v0.2.123 [INFO] [stderr] Compiling memchr v2.4.1 [INFO] [stderr] Compiling autocfg v1.1.0 [INFO] [stderr] Compiling futures-core v0.3.21 [INFO] [stderr] Checking pin-project-lite v0.2.8 [INFO] [stderr] Compiling log v0.4.16 [INFO] [stderr] Compiling futures-channel v0.3.21 [INFO] [stderr] Compiling futures-task v0.3.21 [INFO] [stderr] Checking futures-sink v0.3.21 [INFO] [stderr] Compiling cc v1.0.73 [INFO] [stderr] Compiling futures-util v0.3.21 [INFO] [stderr] Checking futures-io v0.3.21 [INFO] [stderr] Checking gimli v0.26.1 [INFO] [stderr] Checking bytes v1.1.0 [INFO] [stderr] Compiling unicode-segmentation v1.9.0 [INFO] [stderr] Compiling doc-comment v0.3.3 [INFO] [stderr] Compiling parking_lot_core v0.8.5 [INFO] [stderr] Checking adler v1.0.2 [INFO] [stderr] Checking pin-utils v0.1.0 [INFO] [stderr] Checking slab v0.4.6 [INFO] [stderr] Checking rustc-demangle v0.1.21 [INFO] [stderr] Checking smallvec v1.8.0 [INFO] [stderr] Checking scopeguard v1.1.0 [INFO] [stderr] Compiling serde_json v1.0.79 [INFO] [stderr] Checking itoa v1.0.1 [INFO] [stderr] Checking tracing-core v0.1.25 [INFO] [stderr] Checking bincode v1.3.3 [INFO] [stderr] Checking instant v0.1.12 [INFO] [stderr] Compiling miniz_oxide v0.4.4 [INFO] [stderr] Compiling lock_api v0.4.7 [INFO] [stderr] Checking prost v0.10.1 [INFO] [stderr] Compiling heck v0.3.3 [INFO] [stderr] Checking object v0.27.1 [INFO] [stderr] Compiling backtrace v0.3.64 [INFO] [stderr] Compiling quote v1.0.18 [INFO] [stderr] Checking mio v0.8.2 [INFO] [stderr] Checking socket2 v0.4.4 [INFO] [stderr] Checking parking_lot v0.11.2 [INFO] [stderr] Checking addr2line v0.17.0 [INFO] [stderr] Compiling futures-macro v0.3.21 [INFO] [stderr] Compiling tokio-macros v1.7.0 [INFO] [stderr] Compiling tracing-attributes v0.1.20 [INFO] [stderr] Compiling pin-project-internal v1.0.10 [INFO] [stderr] Compiling snafu-derive v0.7.0 [INFO] [stderr] Checking tokio v1.17.0 [INFO] [stderr] Checking pin-project v1.0.10 [INFO] [stderr] Checking tracing v0.1.33 [INFO] [stderr] Checking snafu v0.7.0 [INFO] [stderr] Checking futures-executor v0.3.21 [INFO] [stderr] Checking futures v0.3.21 [INFO] [stderr] Checking tokio-util v0.7.1 [INFO] [stderr] Documenting tsyncp v0.3.0 (/opt/rustwide/workdir) [INFO] [stderr] Finished dev [unoptimized + debuginfo] target(s) in 18.54s [INFO] running `Command { std: "docker" "inspect" "652093a694dde6f4740dc857b7f0e777b15b19c38832b3cbdc917476667deb35", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "652093a694dde6f4740dc857b7f0e777b15b19c38832b3cbdc917476667deb35", kill_on_drop: false }` [INFO] [stdout] 652093a694dde6f4740dc857b7f0e777b15b19c38832b3cbdc917476667deb35 [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-37/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-37/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" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=warn" "-e" "DOCS_RS=1" "-e" "RUSTC_BOOTSTRAP=1" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:d190cb871061d98bc6d0581d85cb2ecb09a0f8a142ba5463de30be9999fc3251" "/opt/rustwide/cargo-home/bin/cargo" "+beta-2022-05-20" "rustdoc" "--lib" "-Zrustdoc-map" "--frozen" "--message-format=json" "--" "-Z" "unstable-options" "--document-private-items", kill_on_drop: false }` [INFO] [stdout] dde38f4eb56af873ad7185acdf4ded5f161fb54c99e2302970bb91b886b44edf [INFO] running `Command { std: "docker" "start" "-a" "dde38f4eb56af873ad7185acdf4ded5f161fb54c99e2302970bb91b886b44edf", kill_on_drop: false }` [INFO] [stderr] Compiling proc-macro2 v1.0.37 [INFO] [stderr] Compiling unicode-xid v0.2.2 [INFO] [stderr] Compiling syn v1.0.91 [INFO] [stderr] Checking cfg-if v1.0.0 [INFO] [stderr] Compiling libc v0.2.123 [INFO] [stderr] Compiling memchr v2.4.1 [INFO] [stderr] Compiling autocfg v1.1.0 [INFO] [stderr] Compiling futures-core v0.3.21 [INFO] [stderr] Checking pin-project-lite v0.2.8 [INFO] [stderr] Compiling futures-task v0.3.21 [INFO] [stderr] Compiling log v0.4.16 [INFO] [stderr] Checking futures-sink v0.3.21 [INFO] [stderr] Compiling futures-channel v0.3.21 [INFO] [stderr] Compiling serde v1.0.136 [INFO] [stderr] Compiling cc v1.0.73 [INFO] [stderr] Compiling futures-util v0.3.21 [INFO] [stderr] Checking futures-io v0.3.21 [INFO] [stderr] Checking pin-utils v0.1.0 [INFO] [stderr] Compiling parking_lot_core v0.8.5 [INFO] [stderr] Checking adler v1.0.2 [INFO] [stderr] Checking lazy_static v1.4.0 [INFO] [stderr] Checking gimli v0.26.1 [INFO] [stderr] Compiling unicode-segmentation v1.9.0 [INFO] [stderr] Compiling doc-comment v0.3.3 [INFO] [stderr] Checking slab v0.4.6 [INFO] [stderr] Checking bytes v1.1.0 [INFO] [stderr] Checking rustc-demangle v0.1.21 [INFO] [stderr] Checking smallvec v1.8.0 [INFO] [stderr] Checking scopeguard v1.1.0 [INFO] [stderr] Compiling serde_json v1.0.79 [INFO] [stderr] Checking ryu v1.0.9 [INFO] [stderr] Checking itoa v1.0.1 [INFO] [stderr] Checking instant v0.1.12 [INFO] [stderr] Checking tracing-core v0.1.25 [INFO] [stderr] Compiling heck v0.3.3 [INFO] [stderr] Checking prost v0.10.1 [INFO] [stderr] Compiling miniz_oxide v0.4.4 [INFO] [stderr] Compiling lock_api v0.4.7 [INFO] [stderr] Compiling backtrace v0.3.64 [INFO] [stderr] Compiling quote v1.0.18 [INFO] [stderr] Checking mio v0.8.2 [INFO] [stderr] Checking socket2 v0.4.4 [INFO] [stderr] Checking object v0.27.1 [INFO] [stderr] Checking parking_lot v0.11.2 [INFO] [stderr] Checking addr2line v0.17.0 [INFO] [stderr] Checking bincode v1.3.3 [INFO] [stderr] Compiling futures-macro v0.3.21 [INFO] [stderr] Compiling pin-project-internal v1.0.10 [INFO] [stderr] Compiling tracing-attributes v0.1.20 [INFO] [stderr] Compiling tokio-macros v1.7.0 [INFO] [stderr] Compiling snafu-derive v0.7.0 [INFO] [stderr] Checking tokio v1.17.0 [INFO] [stderr] Checking pin-project v1.0.10 [INFO] [stderr] Checking tracing v0.1.33 [INFO] [stderr] Checking snafu v0.7.0 [INFO] [stderr] Checking tokio-util v0.7.1 [INFO] [stderr] Checking futures-executor v0.3.21 [INFO] [stderr] Checking futures v0.3.21 [INFO] [stderr] Documenting tsyncp v0.3.0 (/opt/rustwide/workdir) [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/barrier/builder.rs:1:1 [INFO] [stdout] | [INFO] [stdout] 1 | / //! Contains [BarrierBuilderFuture] which builds [barrier::Barrier](super::Barrier), [INFO] [stdout] 2 | | //! and [WaiterBuilderFuture] which builds [barrier::Waiter](super::Waiter). [INFO] [stdout] 3 | | //! [INFO] [stdout] 4 | | //! [BarrierBuilderFuture] is returned by [barrier_on](super::barrier_on) function. [INFO] [stdout] ... | [INFO] [stdout] 9 | | //! [INFO] [stdout] 10 | | //! To see all available configurations, see [BarrierBuilderFuture] and [WaiterBuilderFuture]. [INFO] [stdout] | |______________________________________________________________________________________________^ [INFO] [stdout] | [INFO] [stdout] note: the lint level is defined here [INFO] [stdout] --> src/lib.rs:4:9 [INFO] [stdout] | [INFO] [stdout] 4 | #![warn(rustdoc::missing_doc_code_examples)] [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/barrier/builder.rs:81:1 [INFO] [stdout] | [INFO] [stdout] 81 | / impl WaiterBuilderFuture [INFO] [stdout] 82 | | where [INFO] [stdout] 83 | | A: 'static + Clone + Send + ToSocketAddrs, [INFO] [stdout] 84 | | Filter: Clone + Fn(SocketAddr) -> bool, [INFO] [stdout] ... | [INFO] [stdout] 341 | | } [INFO] [stdout] 342 | | } [INFO] [stdout] | |_^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/barrier/builder.rs:409:1 [INFO] [stdout] | [INFO] [stdout] 409 | / impl BarrierBuilderFuture [INFO] [stdout] 410 | | where [INFO] [stdout] 411 | | A: 'static + Send + Clone + ToSocketAddrs, [INFO] [stdout] 412 | | L: Accept, [INFO] [stdout] ... | [INFO] [stdout] 452 | | } [INFO] [stdout] 453 | | } [INFO] [stdout] | |_^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/barrier/builder.rs:455:1 [INFO] [stdout] | [INFO] [stdout] 455 | / impl BarrierBuilderFuture [INFO] [stdout] 456 | | where [INFO] [stdout] 457 | | A: 'static + Send + Clone + ToSocketAddrs, [INFO] [stdout] 458 | | Fut: Future>>, [INFO] [stdout] ... | [INFO] [stdout] 741 | | } [INFO] [stdout] 742 | | } [INFO] [stdout] | |_^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/barrier/mod.rs:575:1 [INFO] [stdout] | [INFO] [stdout] 575 | / pub mod errors { [INFO] [stdout] 576 | | use super::*; [INFO] [stdout] 577 | | use snafu::Snafu; [INFO] [stdout] 578 | | use std::io; [INFO] [stdout] ... | [INFO] [stdout] 594 | | } [INFO] [stdout] 595 | | } [INFO] [stdout] | |_^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/barrier/mod.rs:583:5 [INFO] [stdout] | [INFO] [stdout] 583 | / pub struct BarrierError { [INFO] [stdout] 584 | | source: multi_channel::errors::SinkError, [INFO] [stdout] 585 | | backtrace: Backtrace, [INFO] [stdout] 586 | | } [INFO] [stdout] | |_____^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/barrier/mod.rs:591:5 [INFO] [stdout] | [INFO] [stdout] 591 | / pub struct WaiterError { [INFO] [stdout] 592 | | source: channel::errors::StreamError, [INFO] [stdout] 593 | | backtrace: Backtrace, [INFO] [stdout] 594 | | } [INFO] [stdout] | |_____^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/barrier/mod.rs:210:1 [INFO] [stdout] | [INFO] [stdout] 210 | / impl Waiter { [INFO] [stdout] 211 | | /// Returns local address [INFO] [stdout] 212 | | pub fn local_addr(&self) -> &SocketAddr { [INFO] [stdout] 213 | | &self.0.local_addr() [INFO] [stdout] ... | [INFO] [stdout] 219 | | } [INFO] [stdout] 220 | | } [INFO] [stdout] | |_^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/barrier/mod.rs:211:5 [INFO] [stdout] | [INFO] [stdout] 211 | /// Returns local address [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/barrier/mod.rs:216:5 [INFO] [stdout] | [INFO] [stdout] 216 | /// Returns peer address [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/barrier/mod.rs:222:1 [INFO] [stdout] | [INFO] [stdout] 222 | / impl Waiter [INFO] [stdout] 223 | | where [INFO] [stdout] 224 | | S: AsyncRead + Unpin, [INFO] [stdout] 225 | | { [INFO] [stdout] ... | [INFO] [stdout] 248 | | } [INFO] [stdout] 249 | | } [INFO] [stdout] | |_^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/barrier/mod.rs:356:1 [INFO] [stdout] | [INFO] [stdout] 356 | / impl Barrier [INFO] [stdout] 357 | | where [INFO] [stdout] 358 | | L: Accept, [INFO] [stdout] 359 | | { [INFO] [stdout] ... | [INFO] [stdout] 493 | | } [INFO] [stdout] 494 | | } [INFO] [stdout] | |_^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/barrier/mod.rs:496:1 [INFO] [stdout] | [INFO] [stdout] 496 | / impl Barrier [INFO] [stdout] 497 | | where [INFO] [stdout] 498 | | L: Accept, [INFO] [stdout] 499 | | { [INFO] [stdout] ... | [INFO] [stdout] 539 | | } [INFO] [stdout] 540 | | } [INFO] [stdout] | |_^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/barrier/mod.rs:542:1 [INFO] [stdout] | [INFO] [stdout] 542 | / impl Barrier [INFO] [stdout] 543 | | where [INFO] [stdout] 544 | | L::Output: AsyncWrite + Unpin, [INFO] [stdout] 545 | | { [INFO] [stdout] ... | [INFO] [stdout] 571 | | } [INFO] [stdout] 572 | | } [INFO] [stdout] | |_^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/broadcast/builder.rs:1:1 [INFO] [stdout] | [INFO] [stdout] 1 | / //! Contains [SenderBuilderFuture] which builds [broadcast::Sender](super::Sender), [INFO] [stdout] 2 | | //! and [ReceiverBuilderFuture] which builds [broadcast::Receiver](super::Receiver). [INFO] [stdout] 3 | | //! [INFO] [stdout] 4 | | //! [SenderBuilderFuture] is returned by [sender_on](super::sender_on) function. [INFO] [stdout] ... | [INFO] [stdout] 9 | | //! [INFO] [stdout] 10 | | //! To see all available configurations, see [SenderBuilderFuture] and [ReceiverBuilderFuture]. [INFO] [stdout] | |_______________________________________________________________________________________________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/broadcast/builder.rs:86:1 [INFO] [stdout] | [INFO] [stdout] 86 | / impl ReceiverBuilderFuture [INFO] [stdout] 87 | | where [INFO] [stdout] 88 | | A: 'static + Clone + Send + ToSocketAddrs, [INFO] [stdout] 89 | | Filter: Clone + Fn(SocketAddr) -> bool, [INFO] [stdout] ... | [INFO] [stdout] 378 | | } [INFO] [stdout] 379 | | } [INFO] [stdout] | |_^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/broadcast/builder.rs:446:1 [INFO] [stdout] | [INFO] [stdout] 446 | / impl SenderBuilderFuture [INFO] [stdout] 447 | | where [INFO] [stdout] 448 | | A: 'static + Send + Clone + ToSocketAddrs, [INFO] [stdout] 449 | | L: Accept, [INFO] [stdout] ... | [INFO] [stdout] 489 | | } [INFO] [stdout] 490 | | } [INFO] [stdout] | |_^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/broadcast/builder.rs:492:1 [INFO] [stdout] | [INFO] [stdout] 492 | / impl SenderBuilderFuture [INFO] [stdout] 493 | | where [INFO] [stdout] 494 | | A: 'static + Send + Clone + ToSocketAddrs, [INFO] [stdout] 495 | | Fut: Future>>, [INFO] [stdout] ... | [INFO] [stdout] 828 | | } [INFO] [stdout] 829 | | } [INFO] [stdout] | |_^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/broadcast/mod.rs:343:1 [INFO] [stdout] | [INFO] [stdout] 343 | / impl Receiver { [INFO] [stdout] 344 | | /// Returns local address [INFO] [stdout] 345 | | pub fn local_addr(&self) -> &SocketAddr { [INFO] [stdout] 346 | | &self.0.local_addr() [INFO] [stdout] ... | [INFO] [stdout] 352 | | } [INFO] [stdout] 353 | | } [INFO] [stdout] | |_^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/broadcast/mod.rs:344:5 [INFO] [stdout] | [INFO] [stdout] 344 | /// Returns local address [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/broadcast/mod.rs:349:5 [INFO] [stdout] | [INFO] [stdout] 349 | /// Returns peer address [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/broadcast/mod.rs:355:1 [INFO] [stdout] | [INFO] [stdout] 355 | / impl, S: AsyncRead + Unpin> Receiver { [INFO] [stdout] 356 | | /// Returns [RecvFuture](crate::channel::recv::RecvFuture) which asynchronously receives an item. [INFO] [stdout] 357 | | /// [INFO] [stdout] 358 | | /// To extend this method by chaining futures, see [RecvFuture](crate::channel::recv::RecvFuture). [INFO] [stdout] ... | [INFO] [stdout] 361 | | } [INFO] [stdout] 362 | | } [INFO] [stdout] | |_^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/broadcast/mod.rs:356:5 [INFO] [stdout] | [INFO] [stdout] 356 | / /// Returns [RecvFuture](crate::channel::recv::RecvFuture) which asynchronously receives an item. [INFO] [stdout] 357 | | /// [INFO] [stdout] 358 | | /// To extend this method by chaining futures, see [RecvFuture](crate::channel::recv::RecvFuture). [INFO] [stdout] | |______________________________________________________________________________________________________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/broadcast/mod.rs:607:1 [INFO] [stdout] | [INFO] [stdout] 607 | / impl Sender [INFO] [stdout] 608 | | where [INFO] [stdout] 609 | | L: Accept, [INFO] [stdout] 610 | | { [INFO] [stdout] ... | [INFO] [stdout] 784 | | } [INFO] [stdout] 785 | | } [INFO] [stdout] | |_^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/broadcast/mod.rs:787:1 [INFO] [stdout] | [INFO] [stdout] 787 | / impl Sender [INFO] [stdout] 788 | | where [INFO] [stdout] 789 | | L: Accept, [INFO] [stdout] 790 | | { [INFO] [stdout] ... | [INFO] [stdout] 830 | | } [INFO] [stdout] 831 | | } [INFO] [stdout] | |_^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/broadcast/mod.rs:833:1 [INFO] [stdout] | [INFO] [stdout] 833 | / impl Sender [INFO] [stdout] 834 | | where [INFO] [stdout] 835 | | E: EncodeMethod, [INFO] [stdout] 836 | | L: Accept, [INFO] [stdout] ... | [INFO] [stdout] 883 | | } [INFO] [stdout] 884 | | } [INFO] [stdout] | |_^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/broadcast/mod.rs:880:5 [INFO] [stdout] | [INFO] [stdout] 880 | /// Renamed method alias for [send](Sender::send). [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/channel/builder.rs:1:1 [INFO] [stdout] | [INFO] [stdout] 1 | / //! Contains [BuilderFuture] which builds [channel::Channel](super::Channel) when `.await`ed. [INFO] [stdout] 2 | | //! [INFO] [stdout] 3 | | //! [BuilderFuture] is returned by [channel_on](super::channel_on) or [channel_to](super::channel_to) function. [INFO] [stdout] 4 | | //! [INFO] [stdout] 5 | | //! Before awaiting the future, you can chain other methods on it to configure the Channel. [INFO] [stdout] 6 | | //! [INFO] [stdout] 7 | | //! To see all available configurations, see [BuilderFuture]. [INFO] [stdout] | |_____________________________________________________________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/channel/builder.rs:593:1 [INFO] [stdout] | [INFO] [stdout] 593 | / pub mod errors { [INFO] [stdout] 594 | | use super::*; [INFO] [stdout] 595 | | use snafu::Snafu; [INFO] [stdout] 596 | | [INFO] [stdout] ... | [INFO] [stdout] 707 | | } [INFO] [stdout] 708 | | } [INFO] [stdout] | |_^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/channel/builder.rs:599:5 [INFO] [stdout] | [INFO] [stdout] 599 | / pub enum BuilderError { [INFO] [stdout] 600 | | #[snafu(display("[BuilderError] Encountered unexpected error on spawned task for converting to socket addr"))] [INFO] [stdout] 601 | | SpawnJoin { [INFO] [stdout] 602 | | /// source Error [INFO] [stdout] ... | [INFO] [stdout] 706 | | }, [INFO] [stdout] 707 | | } [INFO] [stdout] | |_____^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/channel/builder.rs:113:1 [INFO] [stdout] | [INFO] [stdout] 113 | / impl BuilderFuture [INFO] [stdout] 114 | | where [INFO] [stdout] 115 | | A: 'static + Clone + Send + ToSocketAddrs, [INFO] [stdout] 116 | | Filter: Clone + Fn(SocketAddr) -> bool, [INFO] [stdout] ... | [INFO] [stdout] 445 | | } [INFO] [stdout] 446 | | } [INFO] [stdout] | |_^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/channel/recv.rs:1:1 [INFO] [stdout] | [INFO] [stdout] 1 | / //! Contains futures for receiving items on channel. [INFO] [stdout] 2 | | //! [INFO] [stdout] 3 | | //! These futures are built by calling `channel.recv()` and chaining methods to it. [INFO] [stdout] 4 | | //! [INFO] [stdout] 5 | | //! For detailed examples, see each documentation in the structs below. [INFO] [stdout] | |_______________________________________________________________________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/channel/recv.rs:64:1 [INFO] [stdout] | [INFO] [stdout] 64 | / impl<'pin, T, E, S> RecvFuture<'pin, T, E, S> { [INFO] [stdout] 65 | | pub(super) fn new(channel: &'pin mut Channel) -> Self { [INFO] [stdout] 66 | | Self { channel } [INFO] [stdout] 67 | | } [INFO] [stdout] ... | [INFO] [stdout] 97 | | } [INFO] [stdout] 98 | | } [INFO] [stdout] | |_^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/channel/recv.rs:175:1 [INFO] [stdout] | [INFO] [stdout] 175 | / impl<'pin, T, E, S> AsBytesFuture<'pin, T, E, S> { [INFO] [stdout] 176 | | pub(super) fn new(channel: &'pin mut Channel) -> Self { [INFO] [stdout] 177 | | Self { channel } [INFO] [stdout] 178 | | } [INFO] [stdout] 179 | | } [INFO] [stdout] | |_^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/channel/mod.rs:542:1 [INFO] [stdout] | [INFO] [stdout] 542 | / pub mod errors { [INFO] [stdout] 543 | | use super::*; [INFO] [stdout] 544 | | use crate::util::frame_codec::errors::CodecError; [INFO] [stdout] 545 | | use snafu::Snafu; [INFO] [stdout] ... | [INFO] [stdout] 797 | | } [INFO] [stdout] 798 | | } [INFO] [stdout] | |_^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/channel/mod.rs:550:5 [INFO] [stdout] | [INFO] [stdout] 550 | / pub enum SinkError [INFO] [stdout] 551 | | where [INFO] [stdout] 552 | | E: 'static + snafu::Error, [INFO] [stdout] 553 | | { [INFO] [stdout] ... | [INFO] [stdout] 588 | | }, [INFO] [stdout] 589 | | } [INFO] [stdout] | |_____^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/channel/mod.rs:591:5 [INFO] [stdout] | [INFO] [stdout] 591 | / impl SinkError [INFO] [stdout] 592 | | where [INFO] [stdout] 593 | | E: 'static + snafu::Error, [INFO] [stdout] 594 | | { [INFO] [stdout] ... | [INFO] [stdout] 677 | | } [INFO] [stdout] 678 | | } [INFO] [stdout] | |_____^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/channel/mod.rs:595:9 [INFO] [stdout] | [INFO] [stdout] 595 | / pub fn local_addr(&self) -> &SocketAddr { [INFO] [stdout] 596 | | match self { [INFO] [stdout] 597 | | Self::StartSend { addr, .. } => addr, [INFO] [stdout] 598 | | Self::PollReady { addr, .. } => addr, [INFO] [stdout] ... | [INFO] [stdout] 602 | | } [INFO] [stdout] 603 | | } [INFO] [stdout] | |_________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/channel/mod.rs:605:9 [INFO] [stdout] | [INFO] [stdout] 605 | / pub fn peer_addr(&self) -> &SocketAddr { [INFO] [stdout] 606 | | match self { [INFO] [stdout] 607 | | Self::StartSend { peer_addr, .. } => peer_addr, [INFO] [stdout] 608 | | Self::PollReady { peer_addr, .. } => peer_addr, [INFO] [stdout] ... | [INFO] [stdout] 612 | | } [INFO] [stdout] 613 | | } [INFO] [stdout] | |_________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/channel/mod.rs:615:9 [INFO] [stdout] | [INFO] [stdout] 615 | / pub fn is_encode_error(&self) -> bool { [INFO] [stdout] 616 | | matches!(self, Self::ItemEncode { .. }) [INFO] [stdout] 617 | | } [INFO] [stdout] | |_________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/channel/mod.rs:619:9 [INFO] [stdout] | [INFO] [stdout] 619 | / pub fn is_sink_error(&self) -> bool { [INFO] [stdout] 620 | | !self.is_encode_error() [INFO] [stdout] 621 | | } [INFO] [stdout] | |_________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/channel/mod.rs:623:9 [INFO] [stdout] | [INFO] [stdout] 623 | / pub fn as_io(&self) -> Option<&std::io::Error> { [INFO] [stdout] 624 | | match self { [INFO] [stdout] 625 | | Self::StartSend { source, .. } => source.as_io(), [INFO] [stdout] 626 | | Self::PollReady { source, .. } => source.as_io(), [INFO] [stdout] ... | [INFO] [stdout] 630 | | } [INFO] [stdout] 631 | | } [INFO] [stdout] | |_________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/channel/mod.rs:633:9 [INFO] [stdout] | [INFO] [stdout] 633 | / /// Check if the error is a connection error. [INFO] [stdout] 634 | | /// [INFO] [stdout] 635 | | /// Returns `true` if the error either `reset`, `refused`, `aborted`, `not connected`, or [INFO] [stdout] 636 | | /// `broken pipe`. [INFO] [stdout] ... | [INFO] [stdout] 639 | | /// This method will be bubbled up with the error, and also be available at the highest [INFO] [stdout] 640 | | /// level. [INFO] [stdout] | |__________________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/channel/mod.rs:649:9 [INFO] [stdout] | [INFO] [stdout] 649 | / pub fn is_connection_reset(&self) -> bool { [INFO] [stdout] 650 | | self.as_io() [INFO] [stdout] 651 | | .map(|e| e.kind() == ErrorKind::ConnectionReset) [INFO] [stdout] 652 | | .unwrap_or_default() [INFO] [stdout] 653 | | } [INFO] [stdout] | |_________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/channel/mod.rs:655:9 [INFO] [stdout] | [INFO] [stdout] 655 | / pub fn is_connection_refused(&self) -> bool { [INFO] [stdout] 656 | | self.as_io() [INFO] [stdout] 657 | | .map(|e| e.kind() == ErrorKind::ConnectionRefused) [INFO] [stdout] 658 | | .unwrap_or_default() [INFO] [stdout] 659 | | } [INFO] [stdout] | |_________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/channel/mod.rs:661:9 [INFO] [stdout] | [INFO] [stdout] 661 | / pub fn is_connection_aborted(&self) -> bool { [INFO] [stdout] 662 | | self.as_io() [INFO] [stdout] 663 | | .map(|e| e.kind() == ErrorKind::ConnectionAborted) [INFO] [stdout] 664 | | .unwrap_or_default() [INFO] [stdout] 665 | | } [INFO] [stdout] | |_________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/channel/mod.rs:667:9 [INFO] [stdout] | [INFO] [stdout] 667 | / pub fn is_not_connected(&self) -> bool { [INFO] [stdout] 668 | | self.as_io() [INFO] [stdout] 669 | | .map(|e| e.kind() == ErrorKind::NotConnected) [INFO] [stdout] 670 | | .unwrap_or_default() [INFO] [stdout] 671 | | } [INFO] [stdout] | |_________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/channel/mod.rs:673:9 [INFO] [stdout] | [INFO] [stdout] 673 | / pub fn is_broken_pipe(&self) -> bool { [INFO] [stdout] 674 | | self.as_io() [INFO] [stdout] 675 | | .map(|e| e.kind() == ErrorKind::BrokenPipe) [INFO] [stdout] 676 | | .unwrap_or_default() [INFO] [stdout] 677 | | } [INFO] [stdout] | |_________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/channel/mod.rs:682:5 [INFO] [stdout] | [INFO] [stdout] 682 | / pub enum StreamError [INFO] [stdout] 683 | | where [INFO] [stdout] 684 | | E: 'static + snafu::Error, [INFO] [stdout] 685 | | { [INFO] [stdout] ... | [INFO] [stdout] 699 | | }, [INFO] [stdout] 700 | | } [INFO] [stdout] | |_____^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/channel/mod.rs:702:5 [INFO] [stdout] | [INFO] [stdout] 702 | / impl StreamError [INFO] [stdout] 703 | | where [INFO] [stdout] 704 | | E: 'static + snafu::Error, [INFO] [stdout] 705 | | { [INFO] [stdout] ... | [INFO] [stdout] 779 | | } [INFO] [stdout] 780 | | } [INFO] [stdout] | |_____^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/channel/mod.rs:706:9 [INFO] [stdout] | [INFO] [stdout] 706 | / pub fn local_addr(&self) -> &SocketAddr { [INFO] [stdout] 707 | | match self { [INFO] [stdout] 708 | | Self::PollNext { addr, .. } => addr, [INFO] [stdout] 709 | | Self::ItemDecode { addr, .. } => addr, [INFO] [stdout] 710 | | } [INFO] [stdout] 711 | | } [INFO] [stdout] | |_________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/channel/mod.rs:713:9 [INFO] [stdout] | [INFO] [stdout] 713 | / pub fn peer_addr(&self) -> &SocketAddr { [INFO] [stdout] 714 | | match self { [INFO] [stdout] 715 | | Self::ItemDecode { peer_addr, .. } => peer_addr, [INFO] [stdout] 716 | | Self::PollNext { peer_addr, .. } => peer_addr, [INFO] [stdout] 717 | | } [INFO] [stdout] 718 | | } [INFO] [stdout] | |_________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/channel/mod.rs:720:9 [INFO] [stdout] | [INFO] [stdout] 720 | / pub fn is_decode_error(&self) -> bool { [INFO] [stdout] 721 | | matches!(self, Self::ItemDecode { .. }) [INFO] [stdout] 722 | | } [INFO] [stdout] | |_________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/channel/mod.rs:724:9 [INFO] [stdout] | [INFO] [stdout] 724 | / pub fn is_recv_error(&self) -> bool { [INFO] [stdout] 725 | | !self.is_decode_error() [INFO] [stdout] 726 | | } [INFO] [stdout] | |_________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/channel/mod.rs:728:9 [INFO] [stdout] | [INFO] [stdout] 728 | / pub fn as_io(&self) -> Option<&std::io::Error> { [INFO] [stdout] 729 | | match self { [INFO] [stdout] 730 | | Self::PollNext { source, .. } => source.as_io(), [INFO] [stdout] 731 | | _ => None, [INFO] [stdout] 732 | | } [INFO] [stdout] 733 | | } [INFO] [stdout] | |_________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/channel/mod.rs:735:9 [INFO] [stdout] | [INFO] [stdout] 735 | / /// Check if the error is a connection error. [INFO] [stdout] 736 | | /// [INFO] [stdout] 737 | | /// Returns `true` if the error either `reset`, `refused`, `aborted`, `not connected`, or [INFO] [stdout] 738 | | /// `broken pipe`. [INFO] [stdout] ... | [INFO] [stdout] 741 | | /// This method will be bubbled up with the error, and also be available at the highest [INFO] [stdout] 742 | | /// level. [INFO] [stdout] | |__________________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/channel/mod.rs:751:9 [INFO] [stdout] | [INFO] [stdout] 751 | / pub fn is_connection_reset(&self) -> bool { [INFO] [stdout] 752 | | self.as_io() [INFO] [stdout] 753 | | .map(|e| e.kind() == ErrorKind::ConnectionReset) [INFO] [stdout] 754 | | .unwrap_or_default() [INFO] [stdout] 755 | | } [INFO] [stdout] | |_________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/channel/mod.rs:757:9 [INFO] [stdout] | [INFO] [stdout] 757 | / pub fn is_connection_refused(&self) -> bool { [INFO] [stdout] 758 | | self.as_io() [INFO] [stdout] 759 | | .map(|e| e.kind() == ErrorKind::ConnectionRefused) [INFO] [stdout] 760 | | .unwrap_or_default() [INFO] [stdout] 761 | | } [INFO] [stdout] | |_________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/channel/mod.rs:763:9 [INFO] [stdout] | [INFO] [stdout] 763 | / pub fn is_connection_aborted(&self) -> bool { [INFO] [stdout] 764 | | self.as_io() [INFO] [stdout] 765 | | .map(|e| e.kind() == ErrorKind::ConnectionAborted) [INFO] [stdout] 766 | | .unwrap_or_default() [INFO] [stdout] 767 | | } [INFO] [stdout] | |_________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/channel/mod.rs:769:9 [INFO] [stdout] | [INFO] [stdout] 769 | / pub fn is_not_connected(&self) -> bool { [INFO] [stdout] 770 | | self.as_io() [INFO] [stdout] 771 | | .map(|e| e.kind() == ErrorKind::NotConnected) [INFO] [stdout] 772 | | .unwrap_or_default() [INFO] [stdout] 773 | | } [INFO] [stdout] | |_________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/channel/mod.rs:775:9 [INFO] [stdout] | [INFO] [stdout] 775 | / pub fn is_broken_pipe(&self) -> bool { [INFO] [stdout] 776 | | self.as_io() [INFO] [stdout] 777 | | .map(|e| e.kind() == ErrorKind::BrokenPipe) [INFO] [stdout] 778 | | .unwrap_or_default() [INFO] [stdout] 779 | | } [INFO] [stdout] | |_________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/channel/mod.rs:784:5 [INFO] [stdout] | [INFO] [stdout] 784 | / pub enum UnsplitError { [INFO] [stdout] 785 | | #[snafu(display("[UnsplitError] Underlying channels' local addrs are different: {l_local_addr:?} != {r_local_addr:?}"))] [INFO] [stdout] 786 | | UnequalLocalAddr { [INFO] [stdout] 787 | | l_local_addr: SocketAddr, [INFO] [stdout] ... | [INFO] [stdout] 796 | | FramedUnsplit { source: E, backtrace: Backtrace }, [INFO] [stdout] 797 | | } [INFO] [stdout] | |_____^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/channel/mod.rs:354:1 [INFO] [stdout] | [INFO] [stdout] 354 | / impl Channel { [INFO] [stdout] 355 | | /// Returns local address [INFO] [stdout] 356 | | pub fn local_addr(&self) -> &SocketAddr { [INFO] [stdout] 357 | | &self.local_addr [INFO] [stdout] ... | [INFO] [stdout] 363 | | } [INFO] [stdout] 364 | | } [INFO] [stdout] | |_^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/channel/mod.rs:355:5 [INFO] [stdout] | [INFO] [stdout] 355 | /// Returns local address [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/channel/mod.rs:360:5 [INFO] [stdout] | [INFO] [stdout] 360 | /// Returns peer address [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/channel/mod.rs:366:1 [INFO] [stdout] | [INFO] [stdout] 366 | / impl Channel [INFO] [stdout] 367 | | where [INFO] [stdout] 368 | | S: Split, [INFO] [stdout] 369 | | { [INFO] [stdout] ... | [INFO] [stdout] 379 | | } [INFO] [stdout] 380 | | } [INFO] [stdout] | |_^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/channel/mod.rs:370:5 [INFO] [stdout] | [INFO] [stdout] 370 | / /// Splits the Channel into a pair of [broadcast::Receiver](crate::broadcast::Receiver) [INFO] [stdout] 371 | | /// and [mpsc::Sender](crate::mpsc::Sender). [INFO] [stdout] | |________________________________________________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/channel/mod.rs:459:1 [INFO] [stdout] | [INFO] [stdout] 459 | / impl Channel [INFO] [stdout] 460 | | where [INFO] [stdout] 461 | | E: EncodeMethod, [INFO] [stdout] 462 | | S: AsyncWrite + Unpin, [INFO] [stdout] ... | [INFO] [stdout] 467 | | } [INFO] [stdout] 468 | | } [INFO] [stdout] | |_^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/channel/mod.rs:464:5 [INFO] [stdout] | [INFO] [stdout] 464 | /// Asynchronously send item to the peer addr [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/channel/mod.rs:529:1 [INFO] [stdout] | [INFO] [stdout] 529 | / impl, S> Channel [INFO] [stdout] 530 | | where [INFO] [stdout] 531 | | S: AsyncRead + Unpin, [INFO] [stdout] 532 | | { [INFO] [stdout] ... | [INFO] [stdout] 538 | | } [INFO] [stdout] 539 | | } [INFO] [stdout] | |_^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/channel/mod.rs:533:5 [INFO] [stdout] | [INFO] [stdout] 533 | / /// Returns [RecvFuture](recv::RecvFuture) which asynchronously receives an item. [INFO] [stdout] 534 | | /// [INFO] [stdout] 535 | | /// To extend this method by chaining futures, see [RecvFuture](recv::RecvFuture). [INFO] [stdout] | |______________________________________________________________________________________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/mpsc/builder.rs:1:1 [INFO] [stdout] | [INFO] [stdout] 1 | / //! Contains [SenderBuilderFuture] which builds [mpsc::Sender](super::Sender), [INFO] [stdout] 2 | | //! and [ReceiverBuilderFuture] which builds [mpsc::Receiver](super::Receiver). [INFO] [stdout] 3 | | //! [INFO] [stdout] 4 | | //! [SenderBuilderFuture] is returned by [sender_to](super::sender_to) function. [INFO] [stdout] ... | [INFO] [stdout] 9 | | //! [INFO] [stdout] 10 | | //! To see all available configurations, see [SenderBuilderFuture] and [ReceiverBuilderFuture]. [INFO] [stdout] | |_______________________________________________________________________________________________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/mpsc/builder.rs:86:1 [INFO] [stdout] | [INFO] [stdout] 86 | / impl SenderBuilderFuture [INFO] [stdout] 87 | | where [INFO] [stdout] 88 | | A: 'static + Clone + Send + ToSocketAddrs, [INFO] [stdout] 89 | | Filter: Clone + Fn(SocketAddr) -> bool, [INFO] [stdout] ... | [INFO] [stdout] 378 | | } [INFO] [stdout] 379 | | } [INFO] [stdout] | |_^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/mpsc/builder.rs:446:1 [INFO] [stdout] | [INFO] [stdout] 446 | / impl ReceiverBuilderFuture [INFO] [stdout] 447 | | where [INFO] [stdout] 448 | | A: 'static + Send + Clone + ToSocketAddrs, [INFO] [stdout] 449 | | L: Accept, [INFO] [stdout] ... | [INFO] [stdout] 489 | | } [INFO] [stdout] 490 | | } [INFO] [stdout] | |_^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/mpsc/builder.rs:491:1 [INFO] [stdout] | [INFO] [stdout] 491 | / impl ReceiverBuilderFuture [INFO] [stdout] 492 | | where [INFO] [stdout] 493 | | A: 'static + Send + Clone + ToSocketAddrs, [INFO] [stdout] 494 | | Fut: Future>>, [INFO] [stdout] ... | [INFO] [stdout] 827 | | } [INFO] [stdout] 828 | | } [INFO] [stdout] | |_^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/mpsc/mod.rs:346:1 [INFO] [stdout] | [INFO] [stdout] 346 | / impl Sender { [INFO] [stdout] 347 | | /// Returns local address [INFO] [stdout] 348 | | pub fn local_addr(&self) -> &SocketAddr { [INFO] [stdout] 349 | | &self.0.local_addr() [INFO] [stdout] ... | [INFO] [stdout] 355 | | } [INFO] [stdout] 356 | | } [INFO] [stdout] | |_^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/mpsc/mod.rs:347:5 [INFO] [stdout] | [INFO] [stdout] 347 | /// Returns local address [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/mpsc/mod.rs:352:5 [INFO] [stdout] | [INFO] [stdout] 352 | /// Returns peer address [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/mpsc/mod.rs:358:1 [INFO] [stdout] | [INFO] [stdout] 358 | / impl Sender [INFO] [stdout] 359 | | where [INFO] [stdout] 360 | | E: EncodeMethod, [INFO] [stdout] 361 | | S: AsyncWrite + Unpin, [INFO] [stdout] ... | [INFO] [stdout] 366 | | } [INFO] [stdout] 367 | | } [INFO] [stdout] | |_^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/mpsc/mod.rs:363:5 [INFO] [stdout] | [INFO] [stdout] 363 | /// Asynchronously send item to the peer addr [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/mpsc/mod.rs:629:1 [INFO] [stdout] | [INFO] [stdout] 629 | / impl Receiver [INFO] [stdout] 630 | | where [INFO] [stdout] 631 | | L: Accept, [INFO] [stdout] 632 | | { [INFO] [stdout] ... | [INFO] [stdout] 806 | | } [INFO] [stdout] 807 | | } [INFO] [stdout] | |_^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/mpsc/mod.rs:809:1 [INFO] [stdout] | [INFO] [stdout] 809 | / impl Receiver [INFO] [stdout] 810 | | where [INFO] [stdout] 811 | | L: Accept, [INFO] [stdout] 812 | | L::Error: 'static, [INFO] [stdout] ... | [INFO] [stdout] 853 | | } [INFO] [stdout] 854 | | } [INFO] [stdout] | |_^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/mpsc/mod.rs:856:1 [INFO] [stdout] | [INFO] [stdout] 856 | / impl Receiver [INFO] [stdout] 857 | | where [INFO] [stdout] 858 | | E: DecodeMethod, [INFO] [stdout] 859 | | L: Accept, [INFO] [stdout] ... | [INFO] [stdout] 897 | | } [INFO] [stdout] 898 | | } [INFO] [stdout] | |_^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/multi_channel/accept.rs:1:1 [INFO] [stdout] | [INFO] [stdout] 1 | / //! Contains [AcceptFuture], returned by [channel.accept()](crate::multi_channel::Channel::accept), [INFO] [stdout] 2 | | //! which accepts a connection; [INFO] [stdout] 3 | | //! and [ChainedAcceptFuture], returned by either [recv().accepting()](crate::multi_channel::recv::RecvFuture::accepting) [INFO] [stdout] 4 | | //! or [send(_).accepting()](crate::multi_channel::send::SendFuture::accepting), [INFO] [stdout] 5 | | //! which concurrently accepts connections while receiving or sending. [INFO] [stdout] | |______________________________________________________________________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/multi_channel/accept.rs:130:1 [INFO] [stdout] | [INFO] [stdout] 130 | / impl<'pin, T, E, const N: usize, L, H, F> AcceptFuture<'pin, T, E, N, L, H, F> [INFO] [stdout] 131 | | where [INFO] [stdout] 132 | | L: Accept, [INFO] [stdout] 133 | | { [INFO] [stdout] ... | [INFO] [stdout] 429 | | } [INFO] [stdout] 430 | | } [INFO] [stdout] | |_^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/multi_channel/accept.rs:563:1 [INFO] [stdout] | [INFO] [stdout] 563 | / impl WithAcceptFuture [INFO] [stdout] 564 | | where [INFO] [stdout] 565 | | Fut: Future, [INFO] [stdout] 566 | | AFut: Future, [INFO] [stdout] ... | [INFO] [stdout] 575 | | } [INFO] [stdout] 576 | | } [INFO] [stdout] | |_^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/multi_channel/accept.rs:661:1 [INFO] [stdout] | [INFO] [stdout] 661 | / impl<'pin, T, E, const N: usize, L, Fut, H, F> ChainedAcceptFuture<'pin, T, E, N, L, Fut, H, F> [INFO] [stdout] 662 | | where [INFO] [stdout] 663 | | L: Accept, [INFO] [stdout] 664 | | Fut: AsRef> + AsMut> + Future + Unpin, [INFO] [stdout] ... | [INFO] [stdout] 858 | | } [INFO] [stdout] 859 | | } [INFO] [stdout] | |_^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/multi_channel/builder.rs:1:1 [INFO] [stdout] | [INFO] [stdout] 1 | / //! Contains [BuilderFuture] which builds [multi_channel::Channel](super::Channel) when `.await`ed. [INFO] [stdout] 2 | | //! [INFO] [stdout] 3 | | //! [BuilderFuture] is returned by [channel_on](super::channel_on) function. [INFO] [stdout] 4 | | //! [INFO] [stdout] 5 | | //! Before awaiting the future, you can chain other methods on it to configure the Channel. [INFO] [stdout] 6 | | //! [INFO] [stdout] 7 | | //! To see all available configurations, see [BuilderFuture]. [INFO] [stdout] | |_____________________________________________________________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/multi_channel/builder.rs:810:1 [INFO] [stdout] | [INFO] [stdout] 810 | / pub mod errors { [INFO] [stdout] 811 | | use super::*; [INFO] [stdout] 812 | | use snafu::Snafu; [INFO] [stdout] 813 | | [INFO] [stdout] ... | [INFO] [stdout] 932 | | } [INFO] [stdout] 933 | | } [INFO] [stdout] | |_^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/multi_channel/builder.rs:816:5 [INFO] [stdout] | [INFO] [stdout] 816 | / pub enum BuilderError { [INFO] [stdout] 817 | | #[snafu(display("[BuilderError] Encountered unexpected error on spawned task for converting to socket addr"))] [INFO] [stdout] 818 | | SpawnJoin { [INFO] [stdout] 819 | | /// source Error [INFO] [stdout] ... | [INFO] [stdout] 908 | | }, [INFO] [stdout] 909 | | } [INFO] [stdout] | |_____^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/multi_channel/builder.rs:913:5 [INFO] [stdout] | [INFO] [stdout] 913 | / pub enum AcceptingError [INFO] [stdout] 914 | | where [INFO] [stdout] 915 | | LE: 'static + snafu::Error, [INFO] [stdout] 916 | | { [INFO] [stdout] ... | [INFO] [stdout] 922 | | Building { source: BuilderError }, [INFO] [stdout] 923 | | } [INFO] [stdout] | |_____^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/multi_channel/builder.rs:100:1 [INFO] [stdout] | [INFO] [stdout] 100 | / impl BuilderFuture [INFO] [stdout] 101 | | where [INFO] [stdout] 102 | | A: 'static + Send + Clone + ToSocketAddrs, [INFO] [stdout] 103 | | L: Accept, [INFO] [stdout] ... | [INFO] [stdout] 141 | | } [INFO] [stdout] 142 | | } [INFO] [stdout] | |_^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/multi_channel/builder.rs:144:1 [INFO] [stdout] | [INFO] [stdout] 144 | / impl BuilderFuture [INFO] [stdout] 145 | | where [INFO] [stdout] 146 | | A: 'static + Send + Clone + ToSocketAddrs, [INFO] [stdout] 147 | | Fut: Future>>, [INFO] [stdout] ... | [INFO] [stdout] 443 | | } [INFO] [stdout] 444 | | } [INFO] [stdout] | |_^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/multi_channel/builder.rs:477:1 [INFO] [stdout] | [INFO] [stdout] 477 | / impl AcceptBuilderFuture { [INFO] [stdout] 478 | | pub(crate) fn new(fut: Fut, handle: H, filter: F) -> Self { [INFO] [stdout] 479 | | Self { [INFO] [stdout] 480 | | fut, [INFO] [stdout] ... | [INFO] [stdout] 673 | | } [INFO] [stdout] 674 | | } [INFO] [stdout] | |_^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/multi_channel/recv.rs:1:1 [INFO] [stdout] | [INFO] [stdout] 1 | / //! Contains futures for receiving items on channel. [INFO] [stdout] 2 | | //! [INFO] [stdout] 3 | | //! These futures are built by calling `channel.recv()` and chaining methods to it. [INFO] [stdout] 4 | | //! [INFO] [stdout] 5 | | //! For detailed examples, see each documentation in the structs below. [INFO] [stdout] | |_______________________________________________________________________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/multi_channel/recv.rs:75:1 [INFO] [stdout] | [INFO] [stdout] 75 | / impl<'pin, T, E, const N: usize, L> RecvFuture<'pin, T, E, N, L> [INFO] [stdout] 76 | | where [INFO] [stdout] 77 | | L: Accept, [INFO] [stdout] 78 | | { [INFO] [stdout] ... | [INFO] [stdout] 198 | | } [INFO] [stdout] 199 | | } [INFO] [stdout] | |_^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/multi_channel/recv.rs:273:1 [INFO] [stdout] | [INFO] [stdout] 273 | / impl<'pin, T, E, const N: usize, L> WithAddrFuture<'pin, T, E, N, L> [INFO] [stdout] 274 | | where [INFO] [stdout] 275 | | L: Accept, [INFO] [stdout] 276 | | { [INFO] [stdout] ... | [INFO] [stdout] 364 | | } [INFO] [stdout] 365 | | } [INFO] [stdout] | |_^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/multi_channel/recv.rs:449:1 [INFO] [stdout] | [INFO] [stdout] 449 | / impl<'pin, T, E, const N: usize, L> AsBytesFuture<'pin, T, E, N, L> [INFO] [stdout] 450 | | where [INFO] [stdout] 451 | | L: Accept, [INFO] [stdout] 452 | | { [INFO] [stdout] ... | [INFO] [stdout] 540 | | } [INFO] [stdout] 541 | | } [INFO] [stdout] | |_^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/multi_channel/recv.rs:624:1 [INFO] [stdout] | [INFO] [stdout] 624 | / impl<'pin, T, E, const N: usize, L> AsBytesWithAddrFuture<'pin, T, E, N, L> [INFO] [stdout] 625 | | where [INFO] [stdout] 626 | | L: Accept, [INFO] [stdout] 627 | | { [INFO] [stdout] ... | [INFO] [stdout] 683 | | } [INFO] [stdout] 684 | | } [INFO] [stdout] | |_^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/multi_channel/send.rs:1:1 [INFO] [stdout] | [INFO] [stdout] 1 | / //! Contains futures for sending items on channel. [INFO] [stdout] 2 | | //! [INFO] [stdout] 3 | | //! These futures are built by calling `channel.send(item)` and chaining methods to it. [INFO] [stdout] 4 | | //! [INFO] [stdout] 5 | | //! For detailed examples, see each documentation in the structs below. [INFO] [stdout] | |_______________________________________________________________________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/multi_channel/send.rs:104:1 [INFO] [stdout] | [INFO] [stdout] 104 | / impl<'pin, T, E, const N: usize, L> SendFuture<'pin, T, E, N, L> [INFO] [stdout] 105 | | where [INFO] [stdout] 106 | | L: Accept, [INFO] [stdout] 107 | | { [INFO] [stdout] ... | [INFO] [stdout] 274 | | } [INFO] [stdout] 275 | | } [INFO] [stdout] | |_^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/multi_channel/send.rs:394:1 [INFO] [stdout] | [INFO] [stdout] 394 | / impl<'pin, T, E, const N: usize, L, F> SendFilteredFuture<'pin, T, E, N, L, F> [INFO] [stdout] 395 | | where [INFO] [stdout] 396 | | L: Accept, [INFO] [stdout] 397 | | { [INFO] [stdout] ... | [INFO] [stdout] 472 | | } [INFO] [stdout] 473 | | } [INFO] [stdout] | |_^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/multi_channel/mod.rs:1243:1 [INFO] [stdout] | [INFO] [stdout] 1243 | / pub mod errors { [INFO] [stdout] 1244 | | use crate::util::{listener, stream_pool}; [INFO] [stdout] 1245 | | use snafu::{Backtrace, Snafu}; [INFO] [stdout] 1246 | | use std::io::ErrorKind; [INFO] [stdout] ... | [INFO] [stdout] 1506 | | } [INFO] [stdout] 1507 | | } [INFO] [stdout] | |_^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/multi_channel/mod.rs:1251:5 [INFO] [stdout] | [INFO] [stdout] 1251 | / pub enum SinkError [INFO] [stdout] 1252 | | where [INFO] [stdout] 1253 | | E: 'static + snafu::Error, [INFO] [stdout] 1254 | | { [INFO] [stdout] ... | [INFO] [stdout] 1266 | | }, [INFO] [stdout] 1267 | | } [INFO] [stdout] | |_____^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/multi_channel/mod.rs:1270:5 [INFO] [stdout] | [INFO] [stdout] 1270 | / pub struct SinkErrorIterator<'a, I> [INFO] [stdout] 1271 | | where [INFO] [stdout] 1272 | | I: Iterator, [INFO] [stdout] 1273 | | { [INFO] [stdout] 1274 | | iter: Option, [INFO] [stdout] 1275 | | } [INFO] [stdout] | |_____^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/multi_channel/mod.rs:1293:5 [INFO] [stdout] | [INFO] [stdout] 1293 | / pub struct SinkErrorIntoIterator [INFO] [stdout] 1294 | | where [INFO] [stdout] 1295 | | I: Iterator, [INFO] [stdout] 1296 | | { [INFO] [stdout] 1297 | | iter: Option, [INFO] [stdout] 1298 | | } [INFO] [stdout] | |_____^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/multi_channel/mod.rs:1315:5 [INFO] [stdout] | [INFO] [stdout] 1315 | / impl SinkError [INFO] [stdout] 1316 | | where [INFO] [stdout] 1317 | | E: 'static + snafu::Error, [INFO] [stdout] 1318 | | { [INFO] [stdout] ... | [INFO] [stdout] 1371 | | } [INFO] [stdout] 1372 | | } [INFO] [stdout] | |_____^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/multi_channel/mod.rs:1319:9 [INFO] [stdout] | [INFO] [stdout] 1319 | / pub fn local_addr(&self) -> &SocketAddr { [INFO] [stdout] 1320 | | match self { [INFO] [stdout] 1321 | | Self::SinkErrors { addr, .. } => addr, [INFO] [stdout] 1322 | | Self::ItemEncode { addr, .. } => addr, [INFO] [stdout] 1323 | | } [INFO] [stdout] 1324 | | } [INFO] [stdout] | |_________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/multi_channel/mod.rs:1326:9 [INFO] [stdout] | [INFO] [stdout] 1326 | / pub fn peer_addrs(&self) -> Vec { [INFO] [stdout] 1327 | | match self { [INFO] [stdout] 1328 | | Self::SinkErrors { source, .. } => source.peer_addrs(), [INFO] [stdout] 1329 | | Self::ItemEncode { .. } => Vec::new(), [INFO] [stdout] 1330 | | } [INFO] [stdout] 1331 | | } [INFO] [stdout] | |_________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/multi_channel/mod.rs:1333:9 [INFO] [stdout] | [INFO] [stdout] 1333 | / pub fn is_encode_error(&self) -> bool { [INFO] [stdout] 1334 | | matches!(self, Self::ItemEncode { .. }) [INFO] [stdout] 1335 | | } [INFO] [stdout] | |_________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/multi_channel/mod.rs:1337:9 [INFO] [stdout] | [INFO] [stdout] 1337 | / pub fn is_sink_error(&self) -> bool { [INFO] [stdout] 1338 | | !self.is_encode_error() [INFO] [stdout] 1339 | | } [INFO] [stdout] | |_________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/multi_channel/mod.rs:1341:9 [INFO] [stdout] | [INFO] [stdout] 1341 | / pub fn as_sink_errors( [INFO] [stdout] 1342 | | &self, [INFO] [stdout] 1343 | | ) -> SinkErrorIterator<'_, impl Iterator> { [INFO] [stdout] 1344 | | let iter = if let Self::SinkErrors { source, .. } = self { [INFO] [stdout] ... | [INFO] [stdout] 1350 | | SinkErrorIterator { iter } [INFO] [stdout] 1351 | | } [INFO] [stdout] | |_________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/multi_channel/mod.rs:1353:9 [INFO] [stdout] | [INFO] [stdout] 1353 | / pub fn into_sink_errors( [INFO] [stdout] 1354 | | self, [INFO] [stdout] 1355 | | ) -> SinkErrorIntoIterator> { [INFO] [stdout] 1356 | | let iter = if let Self::SinkErrors { source, .. } = self { [INFO] [stdout] ... | [INFO] [stdout] 1362 | | SinkErrorIntoIterator { iter } [INFO] [stdout] 1363 | | } [INFO] [stdout] | |_________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/multi_channel/mod.rs:1365:9 [INFO] [stdout] | [INFO] [stdout] 1365 | / pub fn as_io_errors(&self) -> impl Iterator { [INFO] [stdout] 1366 | | self.as_sink_errors().filter_map(|e| e.as_io()) [INFO] [stdout] 1367 | | } [INFO] [stdout] | |_________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/multi_channel/mod.rs:1369:9 [INFO] [stdout] | [INFO] [stdout] 1369 | / pub fn into_io_errors(self) -> impl Iterator { [INFO] [stdout] 1370 | | self.into_sink_errors().filter_map(|e| e.into_io()) [INFO] [stdout] 1371 | | } [INFO] [stdout] | |_________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/multi_channel/mod.rs:1376:5 [INFO] [stdout] | [INFO] [stdout] 1376 | / pub enum StreamError [INFO] [stdout] 1377 | | where [INFO] [stdout] 1378 | | E: 'static + snafu::Error, [INFO] [stdout] 1379 | | { [INFO] [stdout] ... | [INFO] [stdout] 1391 | | }, [INFO] [stdout] 1392 | | } [INFO] [stdout] | |_____^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/multi_channel/mod.rs:1394:5 [INFO] [stdout] | [INFO] [stdout] 1394 | / impl StreamError [INFO] [stdout] 1395 | | where [INFO] [stdout] 1396 | | E: snafu::Error, [INFO] [stdout] 1397 | | { [INFO] [stdout] ... | [INFO] [stdout] 1471 | | } [INFO] [stdout] 1472 | | } [INFO] [stdout] | |_____^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/multi_channel/mod.rs:1398:9 [INFO] [stdout] | [INFO] [stdout] 1398 | / pub fn local_addr(&self) -> &SocketAddr { [INFO] [stdout] 1399 | | match self { [INFO] [stdout] 1400 | | Self::StreamError { addr, .. } => addr, [INFO] [stdout] 1401 | | Self::ItemDecode { addr, .. } => addr, [INFO] [stdout] 1402 | | } [INFO] [stdout] 1403 | | } [INFO] [stdout] | |_________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/multi_channel/mod.rs:1405:9 [INFO] [stdout] | [INFO] [stdout] 1405 | / pub fn peer_addr(&self) -> Option { [INFO] [stdout] 1406 | | match self { [INFO] [stdout] 1407 | | Self::ItemDecode { .. } => None, [INFO] [stdout] 1408 | | Self::StreamError { source, .. } => Some(*source.peer_addr()), [INFO] [stdout] 1409 | | } [INFO] [stdout] 1410 | | } [INFO] [stdout] | |_________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/multi_channel/mod.rs:1412:9 [INFO] [stdout] | [INFO] [stdout] 1412 | / pub fn is_decode_error(&self) -> bool { [INFO] [stdout] 1413 | | matches!(self, Self::ItemDecode { .. }) [INFO] [stdout] 1414 | | } [INFO] [stdout] | |_________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/multi_channel/mod.rs:1416:9 [INFO] [stdout] | [INFO] [stdout] 1416 | / pub fn is_recv_error(&self) -> bool { [INFO] [stdout] 1417 | | !self.is_decode_error() [INFO] [stdout] 1418 | | } [INFO] [stdout] | |_________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/multi_channel/mod.rs:1420:9 [INFO] [stdout] | [INFO] [stdout] 1420 | / pub fn as_io(&self) -> Option<&std::io::Error> { [INFO] [stdout] 1421 | | match self { [INFO] [stdout] 1422 | | Self::StreamError { source, .. } => source.as_io(), [INFO] [stdout] 1423 | | _ => None, [INFO] [stdout] 1424 | | } [INFO] [stdout] 1425 | | } [INFO] [stdout] | |_________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/multi_channel/mod.rs:1427:9 [INFO] [stdout] | [INFO] [stdout] 1427 | / /// Check if the error is a connection error. [INFO] [stdout] 1428 | | /// [INFO] [stdout] 1429 | | /// Returns `true` if the error either `reset`, `refused`, `aborted`, `not connected`, or [INFO] [stdout] 1430 | | /// `broken pipe`. [INFO] [stdout] ... | [INFO] [stdout] 1433 | | /// This method will be bubbled up with the error, and also be available at the highest [INFO] [stdout] 1434 | | /// level. [INFO] [stdout] | |__________________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/multi_channel/mod.rs:1443:9 [INFO] [stdout] | [INFO] [stdout] 1443 | / pub fn is_connection_reset(&self) -> bool { [INFO] [stdout] 1444 | | self.as_io() [INFO] [stdout] 1445 | | .map(|e| e.kind() == ErrorKind::ConnectionReset) [INFO] [stdout] 1446 | | .unwrap_or_default() [INFO] [stdout] 1447 | | } [INFO] [stdout] | |_________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/multi_channel/mod.rs:1449:9 [INFO] [stdout] | [INFO] [stdout] 1449 | / pub fn is_connection_refused(&self) -> bool { [INFO] [stdout] 1450 | | self.as_io() [INFO] [stdout] 1451 | | .map(|e| e.kind() == ErrorKind::ConnectionRefused) [INFO] [stdout] 1452 | | .unwrap_or_default() [INFO] [stdout] 1453 | | } [INFO] [stdout] | |_________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/multi_channel/mod.rs:1455:9 [INFO] [stdout] | [INFO] [stdout] 1455 | / pub fn is_connection_aborted(&self) -> bool { [INFO] [stdout] 1456 | | self.as_io() [INFO] [stdout] 1457 | | .map(|e| e.kind() == ErrorKind::ConnectionAborted) [INFO] [stdout] 1458 | | .unwrap_or_default() [INFO] [stdout] 1459 | | } [INFO] [stdout] | |_________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/multi_channel/mod.rs:1461:9 [INFO] [stdout] | [INFO] [stdout] 1461 | / pub fn is_not_connected(&self) -> bool { [INFO] [stdout] 1462 | | self.as_io() [INFO] [stdout] 1463 | | .map(|e| e.kind() == ErrorKind::NotConnected) [INFO] [stdout] 1464 | | .unwrap_or_default() [INFO] [stdout] 1465 | | } [INFO] [stdout] | |_________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/multi_channel/mod.rs:1467:9 [INFO] [stdout] | [INFO] [stdout] 1467 | / pub fn is_broken_pipe(&self) -> bool { [INFO] [stdout] 1468 | | self.as_io() [INFO] [stdout] 1469 | | .map(|e| e.kind() == ErrorKind::BrokenPipe) [INFO] [stdout] 1470 | | .unwrap_or_default() [INFO] [stdout] 1471 | | } [INFO] [stdout] | |_________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/multi_channel/mod.rs:1476:5 [INFO] [stdout] | [INFO] [stdout] 1476 | / pub enum UnsplitError { [INFO] [stdout] 1477 | | #[snafu(display("[Unsplit Error] Underlying channels' local addrs are different: {l_local_addr:?} != {r_local_addr:?}"))] [INFO] [stdout] 1478 | | UnequalLocalAddr { [INFO] [stdout] 1479 | | l_local_addr: SocketAddr, [INFO] [stdout] ... | [INFO] [stdout] 1493 | | }, [INFO] [stdout] 1494 | | } [INFO] [stdout] | |_____^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/multi_channel/mod.rs:1498:5 [INFO] [stdout] | [INFO] [stdout] 1498 | / pub enum AcceptError { [INFO] [stdout] 1499 | | #[snafu(display("[Accept Error] Underlying stream pool failed to accept"))] [INFO] [stdout] 1500 | | StreamPoolAcceptError { source: E, backtrace: Backtrace }, [INFO] [stdout] 1501 | | #[snafu(display("[Accept Error] Failed to push accepted stream to stream pool"))] [INFO] [stdout] ... | [INFO] [stdout] 1505 | | }, [INFO] [stdout] 1506 | | } [INFO] [stdout] | |_____^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/multi_channel/mod.rs:668:1 [INFO] [stdout] | [INFO] [stdout] 668 | / impl Channel [INFO] [stdout] 669 | | where [INFO] [stdout] 670 | | L: Accept, [INFO] [stdout] 671 | | { [INFO] [stdout] ... | [INFO] [stdout] 848 | | } [INFO] [stdout] 849 | | } [INFO] [stdout] | |_^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/multi_channel/mod.rs:851:1 [INFO] [stdout] | [INFO] [stdout] 851 | / impl Channel [INFO] [stdout] 852 | | where [INFO] [stdout] 853 | | L: Accept, [INFO] [stdout] 854 | | L::Output: Split, [INFO] [stdout] ... | [INFO] [stdout] 933 | | } [INFO] [stdout] 934 | | } [INFO] [stdout] | |_^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/multi_channel/mod.rs:1023:1 [INFO] [stdout] | [INFO] [stdout] 1023 | / impl Channel [INFO] [stdout] 1024 | | where [INFO] [stdout] 1025 | | L: Accept, [INFO] [stdout] 1026 | | { [INFO] [stdout] ... | [INFO] [stdout] 1067 | | } [INFO] [stdout] 1068 | | } [INFO] [stdout] | |_^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/multi_channel/mod.rs:1070:1 [INFO] [stdout] | [INFO] [stdout] 1070 | / impl Channel [INFO] [stdout] 1071 | | where [INFO] [stdout] 1072 | | L: Accept, [INFO] [stdout] 1073 | | E: DecodeMethod, [INFO] [stdout] ... | [INFO] [stdout] 1111 | | } [INFO] [stdout] 1112 | | } [INFO] [stdout] | |_^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/multi_channel/mod.rs:1138:1 [INFO] [stdout] | [INFO] [stdout] 1138 | / impl Channel [INFO] [stdout] 1139 | | where [INFO] [stdout] 1140 | | E: EncodeMethod, [INFO] [stdout] 1141 | | L: Accept, [INFO] [stdout] ... | [INFO] [stdout] 1183 | | } [INFO] [stdout] 1184 | | } [INFO] [stdout] | |_^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/mod.rs:1:1 [INFO] [stdout] | [INFO] [stdout] 1 | / //! Contains utility traits and structs that help implement primitives. [INFO] [stdout] 2 | | //! [INFO] [stdout] 3 | | //! This module includes traits that generalizes essential parts of the primitives, [INFO] [stdout] 4 | | //! such as [Accept], [Split], and [codec::EncodeMethod] and [codec::DecodeMethod]; [INFO] [stdout] ... | [INFO] [stdout] 7 | | //! [INFO] [stdout] 8 | | //! These implementations make all primitives very generic and allows room for flexible future development. [INFO] [stdout] | |___________________________________________________________________________________________________________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/codec/mod.rs:1:1 [INFO] [stdout] | [INFO] [stdout] 1 | / //! Contains [EncodeMethod] and [DecodeMethod] to generically implement encoding and decoding over [INFO] [stdout] 2 | | //! different libraries. [INFO] [stdout] 3 | | //! [INFO] [stdout] 4 | | //! Module also contains already implemented codecs to be easily used. [INFO] [stdout] | |______________________________________________________________________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/codec/mod.rs:37:5 [INFO] [stdout] | [INFO] [stdout] 37 | /// Error returned by associated method `encode(_)`. [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/codec/mod.rs:40:5 [INFO] [stdout] | [INFO] [stdout] 40 | /// Encode given data. [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/codec/mod.rs:69:5 [INFO] [stdout] | [INFO] [stdout] 69 | /// Error returned by associated method `decode(_)`. [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/codec/mod.rs:72:5 [INFO] [stdout] | [INFO] [stdout] 72 | /// Decode given data. [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/codec/mod.rs:76:1 [INFO] [stdout] | [INFO] [stdout] 76 | / /// Unit struct that encodes and decodes empty tuple. Used for sending empty payloads. [INFO] [stdout] 77 | | /// [INFO] [stdout] 78 | | /// `EmptyCodec` only implements traits for empty tuple `()`, and is created mainly for [barrier](crate::barrier) primitives. [INFO] [stdout] | |_____________________________________________________________________________________________________________________________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/frame_codec/mod.rs:1:1 [INFO] [stdout] | [INFO] [stdout] 1 | //! Contains [VariedLengthDelimitedCodec], custom frame codec implementation. [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/listener.rs:1:1 [INFO] [stdout] | [INFO] [stdout] 1 | / //! Contains [ListenerWrapper], [ReadListener] and [WriteListener] which allows splitting [INFO] [stdout] 2 | | //! generic `Listener` into `ReadListener` and `WriteListener`. [INFO] [stdout] 3 | | //! [INFO] [stdout] 4 | | //! In this library, you can split [multi_channel::Channel](crate::multi_channel::Channel) [INFO] [stdout] ... | [INFO] [stdout] 25 | | //! `Receiver` and `Sender` pair, with `Receiver` taking `ReadListener` as its listener, and [INFO] [stdout] 26 | | //! `Sender` taking `WriteListener` as its listener. [INFO] [stdout] | |____________________________________________________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/listener.rs:376:1 [INFO] [stdout] | [INFO] [stdout] 376 | / pub mod errors { [INFO] [stdout] 377 | | use snafu::{Backtrace, Snafu}; [INFO] [stdout] 378 | | [INFO] [stdout] 379 | | /// Error returned while unsplitting `ReadListener` and `WriteListener`. [INFO] [stdout] ... | [INFO] [stdout] 387 | | } [INFO] [stdout] 388 | | } [INFO] [stdout] | |_^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/listener.rs:379:5 [INFO] [stdout] | [INFO] [stdout] 379 | /// Error returned while unsplitting `ReadListener` and `WriteListener`. [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/listener.rs:37:1 [INFO] [stdout] | [INFO] [stdout] 37 | / /// Wrapper around any type that implements [Accept](crate::util::Accept) and [INFO] [stdout] 38 | | /// its `Accept::Output: Split`. [INFO] [stdout] 39 | | /// [INFO] [stdout] 40 | | /// This struct can be [split](crate::util::Split::split) into [ReadListener] and [WriteListener]. [INFO] [stdout] ... | [INFO] [stdout] 48 | | /// the oldest connection is popped from the queue and new incoming connection is pushed into the [INFO] [stdout] 49 | | /// queue. [INFO] [stdout] | |__________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/listener.rs:78:1 [INFO] [stdout] | [INFO] [stdout] 78 | / impl ListenerWrapper [INFO] [stdout] 79 | | where [INFO] [stdout] 80 | | L: Accept, [INFO] [stdout] 81 | | L::Output: Split, [INFO] [stdout] ... | [INFO] [stdout] 100 | | } [INFO] [stdout] 101 | | } [INFO] [stdout] | |_^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/listener.rs:85:5 [INFO] [stdout] | [INFO] [stdout] 85 | /// Returns new instance of `ListenerWrapper` with default limit of 1024. [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/listener.rs:97:5 [INFO] [stdout] | [INFO] [stdout] 97 | /// Returns the inner listener. [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/listener.rs:115:1 [INFO] [stdout] | [INFO] [stdout] 115 | / impl ListenerWrapper [INFO] [stdout] 116 | | where [INFO] [stdout] 117 | | L: Accept, [INFO] [stdout] 118 | | L::Output: Split, [INFO] [stdout] ... | [INFO] [stdout] 248 | | } [INFO] [stdout] 249 | | } [INFO] [stdout] | |_^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/listener.rs:122:5 [INFO] [stdout] | [INFO] [stdout] 122 | / /// Polls the inner listener; if new connection is received, it splits the connection into [INFO] [stdout] 123 | | /// `ReadHalf` and `WriteHalf`, queues the `WriteHalf` and returns the `ReadHalf`. [INFO] [stdout] 124 | | /// [INFO] [stdout] 125 | | /// If there is a waker stored for the `WriteListener`, it wakes up the waker so that it can [INFO] [stdout] 126 | | /// take the `WriteHalf`. [INFO] [stdout] | |_____________________________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/listener.rs:170:5 [INFO] [stdout] | [INFO] [stdout] 170 | / /// Handles the case where the read listener's accept future is cancelled when it did not yet [INFO] [stdout] 171 | | /// accept a new connection. This is necessary because `TcpListener`'s accept future only wakes [INFO] [stdout] 172 | | /// the last stored waker. So, if the read listener polled it last, and stops polling, the [INFO] [stdout] 173 | | /// listener will try to wake the read listener and leave the write listener hanging. [INFO] [stdout] 174 | | /// [INFO] [stdout] 175 | | /// It wakes up the WriteListener's waker, so that it can continue polling. [INFO] [stdout] | |_______________________________________________________________________________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/listener.rs:186:5 [INFO] [stdout] | [INFO] [stdout] 186 | / /// Polls the inner listener; if new connection is received, it splits the connection into [INFO] [stdout] 187 | | /// `ReadHalf` and `WriteHalf`, queues the `ReadHalf` and returns the `WriteHalf`. [INFO] [stdout] 188 | | /// [INFO] [stdout] 189 | | /// If there is a waker stored for the `ReadListener`, it wakes up the waker so that it can [INFO] [stdout] 190 | | /// take the `ReadHalf`. [INFO] [stdout] | |____________________________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/listener.rs:234:5 [INFO] [stdout] | [INFO] [stdout] 234 | / /// Handles the case where the write listener's accept future is cancelled when it did not yet [INFO] [stdout] 235 | | /// accept a new connection. This is necessary because `TcpListener`'s accept future only wakes [INFO] [stdout] 236 | | /// the last stored waker. So, if the write listener polled it last, and stops polling, the [INFO] [stdout] 237 | | /// listener will try to wake the write listener and leave the read listener hanging. [INFO] [stdout] 238 | | /// [INFO] [stdout] 239 | | /// It wakes up the WriteListener's waker, so that it can continue polling. [INFO] [stdout] | |_______________________________________________________________________________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/listener.rs:251:1 [INFO] [stdout] | [INFO] [stdout] 251 | / /// Wrapper around `ListenerWrapper` which accepts the `ReadHalf` of a new incoming connection. [INFO] [stdout] 252 | | /// [INFO] [stdout] 253 | | /// This struct wraps `ListenerWrapper` with an [Arc](std::sync::Arc), [INFO] [stdout] 254 | | /// which is shared with [WriteListener] when it is split from `ListenerWrapper`. [INFO] [stdout] 255 | | /// [INFO] [stdout] 256 | | /// This struct implements `Accept`, which accepts and returns the `ReadHalf` of a connection, and [INFO] [stdout] 257 | | /// queues the `WriteHalf` into the write listener's queue. [INFO] [stdout] | |___________________________________________________________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/listener.rs:294:1 [INFO] [stdout] | [INFO] [stdout] 294 | / /// Wrapper around `ListenerWrapper` which accepts the `WriteHalf` of a new incoming connection. [INFO] [stdout] 295 | | /// [INFO] [stdout] 296 | | /// This struct wraps `ListenerWrapper` with an [Arc](std::sync::Arc), [INFO] [stdout] 297 | | /// which is shared with [ReadListener] when it is split from `ListenerWrapper`. [INFO] [stdout] 298 | | /// [INFO] [stdout] 299 | | /// This struct implements `Accept`, which accepts and returns the `WriteHalf` of a connection, and [INFO] [stdout] 300 | | /// queues the `ReadHalf` into the read listener's queue. [INFO] [stdout] | |_________________________________________________________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/stream_pool.rs:1:1 [INFO] [stdout] | [INFO] [stdout] 1 | //! Contains [StreamPool], which listens from all connections, and broadcasts to all connections. [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/stream_pool.rs:699:1 [INFO] [stdout] | [INFO] [stdout] 699 | / pub mod errors { [INFO] [stdout] 700 | | use crate::util::frame_codec; [INFO] [stdout] 701 | | use snafu::{Backtrace, GenerateImplicitData, Snafu}; [INFO] [stdout] 702 | | use std::{ [INFO] [stdout] ... | [INFO] [stdout] 917 | | } [INFO] [stdout] 918 | | } [INFO] [stdout] | |_^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/stream_pool.rs:711:5 [INFO] [stdout] | [INFO] [stdout] 711 | / pub enum StreamPoolError { [INFO] [stdout] 712 | | #[snafu(display( [INFO] [stdout] 713 | | "[StreamPoolError] Cannot add stream to pool as limit {limit} is already reached." [INFO] [stdout] 714 | | ))] [INFO] [stdout] 715 | | AddStreamLimitReached { limit: usize, backtrace: Backtrace }, [INFO] [stdout] 716 | | } [INFO] [stdout] | |_____^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/stream_pool.rs:721:5 [INFO] [stdout] | [INFO] [stdout] 721 | / pub struct SinkErrors { [INFO] [stdout] 722 | | source: SinkErrorsInner, [INFO] [stdout] 723 | | backtrace: Backtrace, [INFO] [stdout] 724 | | } [INFO] [stdout] | |_____^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/stream_pool.rs:727:5 [INFO] [stdout] | [INFO] [stdout] 727 | / pub struct SinkErrorsInner { [INFO] [stdout] 728 | | errors: Vec, [INFO] [stdout] 729 | | } [INFO] [stdout] | |_____^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/stream_pool.rs:770:5 [INFO] [stdout] | [INFO] [stdout] 770 | / impl SinkErrors { [INFO] [stdout] 771 | | pub fn new(errors: Vec) -> Self { [INFO] [stdout] 772 | | Self { [INFO] [stdout] 773 | | source: SinkErrorsInner { errors }, [INFO] [stdout] ... | [INFO] [stdout] 796 | | } [INFO] [stdout] 797 | | } [INFO] [stdout] | |_____^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/stream_pool.rs:771:9 [INFO] [stdout] | [INFO] [stdout] 771 | / pub fn new(errors: Vec) -> Self { [INFO] [stdout] 772 | | Self { [INFO] [stdout] 773 | | source: SinkErrorsInner { errors }, [INFO] [stdout] 774 | | backtrace: Backtrace::generate(), [INFO] [stdout] 775 | | } [INFO] [stdout] 776 | | } [INFO] [stdout] | |_________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/stream_pool.rs:778:9 [INFO] [stdout] | [INFO] [stdout] 778 | / pub fn peer_addrs(&self) -> Vec { [INFO] [stdout] 779 | | self.iter().map(|e| e.peer_addr().to_owned()).collect() [INFO] [stdout] 780 | | } [INFO] [stdout] | |_________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/stream_pool.rs:782:9 [INFO] [stdout] | [INFO] [stdout] 782 | / pub fn iter(&self) -> impl Iterator { [INFO] [stdout] 783 | | self.source.errors.iter() [INFO] [stdout] 784 | | } [INFO] [stdout] | |_________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/stream_pool.rs:786:9 [INFO] [stdout] | [INFO] [stdout] 786 | / pub fn into_iter(self) -> impl Iterator { [INFO] [stdout] 787 | | self.source.errors.into_iter() [INFO] [stdout] 788 | | } [INFO] [stdout] | |_________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/stream_pool.rs:790:9 [INFO] [stdout] | [INFO] [stdout] 790 | / pub fn as_io_errors(&self) -> impl Iterator { [INFO] [stdout] 791 | | self.iter().filter_map(|e| e.as_io()) [INFO] [stdout] 792 | | } [INFO] [stdout] | |_________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/stream_pool.rs:794:9 [INFO] [stdout] | [INFO] [stdout] 794 | / pub fn into_io_errors(self) -> impl Iterator { [INFO] [stdout] 795 | | self.into_iter().filter_map(|e| e.into_io()) [INFO] [stdout] 796 | | } [INFO] [stdout] | |_________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/stream_pool.rs:801:5 [INFO] [stdout] | [INFO] [stdout] 801 | / pub enum UnsplitError [INFO] [stdout] 802 | | where [INFO] [stdout] 803 | | E: 'static + snafu::Error, [INFO] [stdout] 804 | | { [INFO] [stdout] ... | [INFO] [stdout] 808 | | Unsplit { source: E, backtrace: Backtrace }, [INFO] [stdout] 809 | | } [INFO] [stdout] | |_____^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/stream_pool.rs:813:5 [INFO] [stdout] | [INFO] [stdout] 813 | / pub enum PollError { [INFO] [stdout] 814 | | #[snafu(display("[PollError] Error start sending to {addr}"))] [INFO] [stdout] 815 | | StartSend { [INFO] [stdout] 816 | | addr: SocketAddr, [INFO] [stdout] ... | [INFO] [stdout] 838 | | }, [INFO] [stdout] 839 | | } [INFO] [stdout] | |_____^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/stream_pool.rs:841:5 [INFO] [stdout] | [INFO] [stdout] 841 | / impl PollError { [INFO] [stdout] 842 | | pub fn peer_addr(&self) -> &SocketAddr { [INFO] [stdout] 843 | | match self { [INFO] [stdout] 844 | | Self::StartSend { addr, .. } => addr, [INFO] [stdout] ... | [INFO] [stdout] 916 | | } [INFO] [stdout] 917 | | } [INFO] [stdout] | |_____^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/stream_pool.rs:842:9 [INFO] [stdout] | [INFO] [stdout] 842 | / pub fn peer_addr(&self) -> &SocketAddr { [INFO] [stdout] 843 | | match self { [INFO] [stdout] 844 | | Self::StartSend { addr, .. } => addr, [INFO] [stdout] 845 | | Self::PollReady { addr, .. } => addr, [INFO] [stdout] ... | [INFO] [stdout] 849 | | } [INFO] [stdout] 850 | | } [INFO] [stdout] | |_________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/stream_pool.rs:852:9 [INFO] [stdout] | [INFO] [stdout] 852 | / pub fn as_io(&self) -> Option<&std::io::Error> { [INFO] [stdout] 853 | | match self { [INFO] [stdout] 854 | | Self::StartSend { source, .. } => source.as_io(), [INFO] [stdout] 855 | | Self::PollReady { source, .. } => source.as_io(), [INFO] [stdout] ... | [INFO] [stdout] 859 | | } [INFO] [stdout] 860 | | } [INFO] [stdout] | |_________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/stream_pool.rs:862:9 [INFO] [stdout] | [INFO] [stdout] 862 | / pub fn into_io(self) -> Option { [INFO] [stdout] 863 | | match self { [INFO] [stdout] 864 | | Self::StartSend { source, .. } => source.into_io(), [INFO] [stdout] 865 | | Self::PollReady { source, .. } => source.into_io(), [INFO] [stdout] ... | [INFO] [stdout] 869 | | } [INFO] [stdout] 870 | | } [INFO] [stdout] | |_________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/stream_pool.rs:872:9 [INFO] [stdout] | [INFO] [stdout] 872 | / /// Check if the error is a connection error. [INFO] [stdout] 873 | | /// [INFO] [stdout] 874 | | /// Returns `true` if the error either `reset`, `refused`, `aborted`, `not connected`, or [INFO] [stdout] 875 | | /// `broken pipe`. [INFO] [stdout] ... | [INFO] [stdout] 878 | | /// This method will be bubbled up with the error, and also be available at the highest [INFO] [stdout] 879 | | /// level. [INFO] [stdout] | |__________________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/stream_pool.rs:888:9 [INFO] [stdout] | [INFO] [stdout] 888 | / pub fn is_connection_reset(&self) -> bool { [INFO] [stdout] 889 | | self.as_io() [INFO] [stdout] 890 | | .map(|e| e.kind() == io::ErrorKind::ConnectionReset) [INFO] [stdout] 891 | | .unwrap_or_default() [INFO] [stdout] 892 | | } [INFO] [stdout] | |_________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/stream_pool.rs:894:9 [INFO] [stdout] | [INFO] [stdout] 894 | / pub fn is_connection_refused(&self) -> bool { [INFO] [stdout] 895 | | self.as_io() [INFO] [stdout] 896 | | .map(|e| e.kind() == io::ErrorKind::ConnectionRefused) [INFO] [stdout] 897 | | .unwrap_or_default() [INFO] [stdout] 898 | | } [INFO] [stdout] | |_________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/stream_pool.rs:900:9 [INFO] [stdout] | [INFO] [stdout] 900 | / pub fn is_connection_aborted(&self) -> bool { [INFO] [stdout] 901 | | self.as_io() [INFO] [stdout] 902 | | .map(|e| e.kind() == io::ErrorKind::ConnectionAborted) [INFO] [stdout] 903 | | .unwrap_or_default() [INFO] [stdout] 904 | | } [INFO] [stdout] | |_________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/stream_pool.rs:906:9 [INFO] [stdout] | [INFO] [stdout] 906 | / pub fn is_not_connected(&self) -> bool { [INFO] [stdout] 907 | | self.as_io() [INFO] [stdout] 908 | | .map(|e| e.kind() == io::ErrorKind::NotConnected) [INFO] [stdout] 909 | | .unwrap_or_default() [INFO] [stdout] 910 | | } [INFO] [stdout] | |_________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/stream_pool.rs:912:9 [INFO] [stdout] | [INFO] [stdout] 912 | / pub fn is_broken_pipe(&self) -> bool { [INFO] [stdout] 913 | | self.as_io() [INFO] [stdout] 914 | | .map(|e| e.kind() == io::ErrorKind::BrokenPipe) [INFO] [stdout] 915 | | .unwrap_or_default() [INFO] [stdout] 916 | | } [INFO] [stdout] | |_________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/stream_pool.rs:18:1 [INFO] [stdout] | [INFO] [stdout] 18 | / /// Pool of byte streams (i.e. TcpStream), which manages receiving and send to the [INFO] [stdout] 19 | | /// underlying connections. [INFO] [stdout] 20 | | /// [INFO] [stdout] 21 | | /// First generic parameter `S` is the type of the underlying byte stream, and const generic `N` is [INFO] [stdout] ... | [INFO] [stdout] 43 | | /// them after data is flushed. When an error is encountered, the pool removes the errored stream [INFO] [stdout] 44 | | /// from the pool, stores the error, then continues polling to the next stream. [INFO] [stdout] | |_______________________________________________________________________________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/stream_pool.rs:67:1 [INFO] [stdout] | [INFO] [stdout] 67 | / impl StreamPool { [INFO] [stdout] 68 | | /// Wrap the given byte stream into [Framed](crate::util::Framed), then push it into the pool. [INFO] [stdout] 69 | | pub fn push_stream(&mut self, stream: S, addr: SocketAddr) -> Result<()> { [INFO] [stdout] 70 | | let parts = FramedParts::new(stream, VariedLengthDelimitedCodec::new()); [INFO] [stdout] ... | [INFO] [stdout] 73 | | } [INFO] [stdout] 74 | | } [INFO] [stdout] | |_^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/stream_pool.rs:68:5 [INFO] [stdout] | [INFO] [stdout] 68 | /// Wrap the given byte stream into [Framed](crate::util::Framed), then push it into the pool. [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/stream_pool.rs:170:1 [INFO] [stdout] | [INFO] [stdout] 170 | / impl StreamPool { [INFO] [stdout] 171 | | /// Returns `true` is this pool uses an array to store streams. [INFO] [stdout] 172 | | pub fn is_array(&self) -> bool { [INFO] [stdout] 173 | | matches!(self.pool, Pool::Array { .. }) [INFO] [stdout] ... | [INFO] [stdout] 406 | | } [INFO] [stdout] 407 | | } [INFO] [stdout] | |_^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/stream_pool.rs:171:5 [INFO] [stdout] | [INFO] [stdout] 171 | /// Returns `true` is this pool uses an array to store streams. [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/stream_pool.rs:176:5 [INFO] [stdout] | [INFO] [stdout] 176 | /// Returns `true` is this pool uses a Vec to store streams. [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/stream_pool.rs:181:5 [INFO] [stdout] | [INFO] [stdout] 181 | / /// Returns pool with an array of streams with limit `M`. [INFO] [stdout] 182 | | /// [INFO] [stdout] 183 | | /// Attempt to push a stream when the pool already has `M` streams will return an error. [INFO] [stdout] | |____________________________________________________________________________________________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/stream_pool.rs:197:5 [INFO] [stdout] | [INFO] [stdout] 197 | /// Returns pool with a vec of streams with no limit or capacity. [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/stream_pool.rs:211:5 [INFO] [stdout] | [INFO] [stdout] 211 | /// Returns a pool with a vec of streams with a capacity but without limit. [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/stream_pool.rs:225:5 [INFO] [stdout] | [INFO] [stdout] 225 | / /// Returns a pool with a vec of streams with a limit. [INFO] [stdout] 226 | | /// [INFO] [stdout] 227 | | /// Attempt to push a stream when the pool already has already reached the limit will return an error. [INFO] [stdout] | |__________________________________________________________________________________________________________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/stream_pool.rs:241:5 [INFO] [stdout] | [INFO] [stdout] 241 | /// Returns current number of streams in the pool. [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/stream_pool.rs:249:5 [INFO] [stdout] | [INFO] [stdout] 249 | /// Returns total number of streams available in the pool. [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/stream_pool.rs:257:5 [INFO] [stdout] | [INFO] [stdout] 257 | /// Returns remote addresses of all streams in the pool. [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/stream_pool.rs:269:5 [INFO] [stdout] | [INFO] [stdout] 269 | /// Returns a reference of stream and address at the index. [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/stream_pool.rs:283:5 [INFO] [stdout] | [INFO] [stdout] 283 | /// Returns a mutable reference of stream and address at the index. [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/stream_pool.rs:297:5 [INFO] [stdout] | [INFO] [stdout] 297 | / /// Push a stream into the pool. [INFO] [stdout] 298 | | /// [INFO] [stdout] 299 | | /// This will return an error if attempted to push a stream while pool is full. [INFO] [stdout] | |___________________________________________________________________________________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/stream_pool.rs:324:5 [INFO] [stdout] | [INFO] [stdout] 324 | /// Pops and returns a stream from the pool. [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/stream_pool.rs:347:5 [INFO] [stdout] | [INFO] [stdout] 347 | /// Swaps a stream at the index with the last element, and pops that element. [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/stream_pool.rs:473:1 [INFO] [stdout] | [INFO] [stdout] 473 | / impl StreamPool { [INFO] [stdout] 474 | | pub(crate) fn get_indices(&self, filter: &Filter) -> Vec [INFO] [stdout] 475 | | where [INFO] [stdout] 476 | | Filter: Fn(SocketAddr) -> bool, [INFO] [stdout] ... | [INFO] [stdout] 572 | | } [INFO] [stdout] 573 | | } [INFO] [stdout] | |_^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/stream_pool.rs:575:1 [INFO] [stdout] | [INFO] [stdout] 575 | / impl StreamPool { [INFO] [stdout] 576 | | // poll on all streams in the pool, while skipping the ones that already returned ready. [INFO] [stdout] 577 | | fn poll_all(&mut self, mut f: F) -> Poll> [INFO] [stdout] 578 | | where [INFO] [stdout] ... | [INFO] [stdout] 619 | | } [INFO] [stdout] 620 | | } [INFO] [stdout] | |_^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/tcp.rs:1:1 [INFO] [stdout] | [INFO] [stdout] 1 | //! Light wrappers around [tokio::net::tcp]'s [OwnedReadHalf](tokio::net::tcp::OwnedReadHalf) and [OwnedWriteHalf](tokio::net::tcp::OwnedWriteHalf). [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/tcp.rs:25:1 [INFO] [stdout] | [INFO] [stdout] 25 | /// Light wrapper around [tokio::net::tcp::OwnedReadHalf]. [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/tcp.rs:61:1 [INFO] [stdout] | [INFO] [stdout] 61 | / /// Light wrapper around [tokio::net::tcp::OwnedWriteHalf] to stop it from shutting down TCP stream when [INFO] [stdout] 62 | | /// it drops. [INFO] [stdout] | |_____________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: missing code example in this documentation [INFO] [stdout] --> src/util/tcp.rs:69:1 [INFO] [stdout] | [INFO] [stdout] 69 | / impl OwnedWriteHalf { [INFO] [stdout] 70 | | // Should be only used before dropping the struct. [INFO] [stdout] 71 | | fn take_inner(&mut self) -> tcp::OwnedWriteHalf { [INFO] [stdout] 72 | | let inner = self.inner.take().expect("should exist"); [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/util/mod.rs:28:1 [INFO] [stdout] | [INFO] [stdout] 28 | / /// Settings used for TCP streams as `nodelay` and `ttl`. [INFO] [stdout] 29 | | /// [INFO] [stdout] 30 | | /// This struct is used as the associated type `Config` for the trait [Accept] by `TcpListener` . [INFO] [stdout] | |_________________________________________________________________________________________________^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: 206 warnings emitted [INFO] [stdout] [INFO] [stdout] [INFO] [stderr] Finished dev [unoptimized + debuginfo] target(s) in 18.00s [INFO] running `Command { std: "docker" "inspect" "dde38f4eb56af873ad7185acdf4ded5f161fb54c99e2302970bb91b886b44edf", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "dde38f4eb56af873ad7185acdf4ded5f161fb54c99e2302970bb91b886b44edf", kill_on_drop: false }` [INFO] [stdout] dde38f4eb56af873ad7185acdf4ded5f161fb54c99e2302970bb91b886b44edf