[INFO] cloning repository https://github.com/silvadanilo/stubborn-delivery [INFO] running `Command { std: "git" "-c" "credential.helper=" "-c" "credential.helper=/workspace/cargo-home/bin/git-credential-null" "clone" "--bare" "https://github.com/silvadanilo/stubborn-delivery" "/workspace/cache/git-repos/https%3A%2F%2Fgithub.com%2Fsilvadanilo%2Fstubborn-delivery", kill_on_drop: false }` [INFO] [stderr] Cloning into bare repository '/workspace/cache/git-repos/https%3A%2F%2Fgithub.com%2Fsilvadanilo%2Fstubborn-delivery'... [INFO] running `Command { std: "git" "rev-parse" "HEAD", kill_on_drop: false }` [INFO] [stdout] 5596fbd1403363002bb595b86f9679912b88d0a4 [INFO] checking silvadanilo/stubborn-delivery against try#f47dd4da3ae8c32c9e65d307bfe640b143e674df for pr-77526 [INFO] running `Command { std: "git" "clone" "/workspace/cache/git-repos/https%3A%2F%2Fgithub.com%2Fsilvadanilo%2Fstubborn-delivery" "/workspace/builds/worker-4/source", kill_on_drop: false }` [INFO] [stderr] Cloning into '/workspace/builds/worker-4/source'... [INFO] [stderr] done. [INFO] validating manifest of git repo https://github.com/silvadanilo/stubborn-delivery on toolchain f47dd4da3ae8c32c9e65d307bfe640b143e674df [INFO] running `Command { std: "/workspace/cargo-home/bin/cargo" "+f47dd4da3ae8c32c9e65d307bfe640b143e674df" "read-manifest" "--manifest-path" "Cargo.toml", kill_on_drop: false }` [INFO] started tweaking git repo https://github.com/silvadanilo/stubborn-delivery [INFO] finished tweaking git repo https://github.com/silvadanilo/stubborn-delivery [INFO] tweaked toml for git repo https://github.com/silvadanilo/stubborn-delivery written to /workspace/builds/worker-4/source/Cargo.toml [INFO] crate git repo https://github.com/silvadanilo/stubborn-delivery already has a lockfile, it will not be regenerated [INFO] running `Command { std: "/workspace/cargo-home/bin/cargo" "+f47dd4da3ae8c32c9e65d307bfe640b143e674df" "fetch" "--locked" "--manifest-path" "Cargo.toml", kill_on_drop: false }` [INFO] [stderr] Updating crates.io index [INFO] [stderr] Updating git repository `https://github.com/tokio-rs/tokio-line` [INFO] [stderr] error: the lock file /workspace/builds/worker-4/source/Cargo.lock needs to be updated but --locked was passed to prevent this [INFO] [stderr] If you want to try to generate the lock file without accessing the network, use the --offline flag. [INFO] the lockfile is outdated, regenerating it [INFO] running `Command { std: "/workspace/cargo-home/bin/cargo" "+f47dd4da3ae8c32c9e65d307bfe640b143e674df" "generate-lockfile" "--manifest-path" "Cargo.toml" "-Zno-index-update", kill_on_drop: false }` [INFO] [stderr] Blocking waiting for file lock on package cache [INFO] [stderr] Updating git repository `https://github.com/tokio-rs/tokio-line` [INFO] running `Command { std: "/workspace/cargo-home/bin/cargo" "+f47dd4da3ae8c32c9e65d307bfe640b143e674df" "fetch" "--locked" "--manifest-path" "Cargo.toml", kill_on_drop: false }` [INFO] [stderr] Blocking waiting for file lock on package cache [INFO] [stderr] Blocking waiting for file lock on package cache [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-4/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-4/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" "rustops/crates-build-env@sha256:d92eaeed33fa75130ca1ee6c8a01d1ffb62bac859dfdfb3450e3e5d1c0146529" "/opt/rustwide/cargo-home/bin/cargo" "+f47dd4da3ae8c32c9e65d307bfe640b143e674df" "metadata" "--no-deps" "--format-version=1", kill_on_drop: false }` [INFO] [stdout] a42e8804c2a1896ff1d0602da271fc8239cff183cd2cbbd0ebaa688e8fd103fd [INFO] [stderr] WARNING: Your kernel does not support swap limit capabilities or the cgroup is not mounted. Memory limited without swap. [INFO] running `Command { std: "docker" "start" "-a" "a42e8804c2a1896ff1d0602da271fc8239cff183cd2cbbd0ebaa688e8fd103fd", kill_on_drop: false }` [INFO] running `Command { std: "docker" "inspect" "a42e8804c2a1896ff1d0602da271fc8239cff183cd2cbbd0ebaa688e8fd103fd", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "a42e8804c2a1896ff1d0602da271fc8239cff183cd2cbbd0ebaa688e8fd103fd", kill_on_drop: false }` [INFO] [stdout] a42e8804c2a1896ff1d0602da271fc8239cff183cd2cbbd0ebaa688e8fd103fd [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-4/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-4/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=forbid" "-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" "rustops/crates-build-env@sha256:d92eaeed33fa75130ca1ee6c8a01d1ffb62bac859dfdfb3450e3e5d1c0146529" "/opt/rustwide/cargo-home/bin/cargo" "+f47dd4da3ae8c32c9e65d307bfe640b143e674df" "check" "--frozen" "--all" "--all-targets" "--message-format=json", kill_on_drop: false }` [INFO] [stdout] f9d70b12ac5dd19f7062b706bfdc9e9cf75ac03b68029cad5bb239ace1084a4f [INFO] [stderr] WARNING: Your kernel does not support swap limit capabilities or the cgroup is not mounted. Memory limited without swap. [INFO] running `Command { std: "docker" "start" "-a" "f9d70b12ac5dd19f7062b706bfdc9e9cf75ac03b68029cad5bb239ace1084a4f", kill_on_drop: false }` [INFO] [stderr] Checking futures v0.1.30 [INFO] [stderr] Compiling semver-parser v0.7.0 [INFO] [stderr] Checking termcolor v1.1.0 [INFO] [stderr] Checking slab v0.3.0 [INFO] [stderr] Checking take v0.1.0 [INFO] [stderr] Checking smallvec v0.2.1 [INFO] [stderr] Checking humantime v1.3.0 [INFO] [stderr] Checking lock_api v0.3.4 [INFO] [stderr] Checking log v0.4.11 [INFO] [stderr] Checking getopts v0.2.21 [INFO] [stderr] Checking smallvec v0.6.13 [INFO] [stderr] Checking iovec v0.1.4 [INFO] [stderr] Checking net2 v0.2.35 [INFO] [stderr] Checking num_cpus v1.13.0 [INFO] [stderr] Checking rand v0.4.6 [INFO] [stderr] Checking atty v0.2.14 [INFO] [stderr] Checking crossbeam-epoch v0.8.2 [INFO] [stderr] Checking crossbeam-queue v0.2.3 [INFO] [stderr] Checking bytes v0.4.12 [INFO] [stderr] Checking mio v0.6.22 [INFO] [stderr] Checking log v0.3.9 [INFO] [stderr] Compiling semver v0.9.0 [INFO] [stderr] Checking env_logger v0.7.1 [INFO] [stderr] Checking env_logger v0.5.13 [INFO] [stderr] Checking crossbeam-deque v0.7.3 [INFO] [stderr] Compiling rustc_version v0.2.3 [INFO] [stderr] Checking rand v0.3.23 [INFO] [stderr] Checking quickcheck v0.6.2 [INFO] [stderr] Checking mio-uds v0.6.8 [INFO] [stderr] Compiling parking_lot_core v0.6.2 [INFO] [stderr] Compiling parking_lot v0.9.0 [INFO] [stderr] Checking tokio-executor v0.1.10 [INFO] [stderr] Checking tokio-io v0.1.13 [INFO] [stderr] Checking tokio-sync v0.1.8 [INFO] [stderr] Checking tokio-service v0.1.0 [INFO] [stderr] Checking tokio-timer v0.1.2 [INFO] [stderr] Checking tokio-threadpool v0.1.18 [INFO] [stderr] Checking tokio-timer v0.2.13 [INFO] [stderr] Checking tokio-current-thread v0.1.7 [INFO] [stderr] Checking tokio-codec v0.1.2 [INFO] [stderr] Checking tokio-reactor v0.1.12 [INFO] [stderr] Checking tokio-fs v0.1.7 [INFO] [stderr] Checking tokio-udp v0.1.6 [INFO] [stderr] Checking tokio-uds v0.2.7 [INFO] [stderr] Checking tokio-tcp v0.1.4 [INFO] [stderr] Checking tokio v0.1.22 [INFO] [stderr] Checking tokio-core v0.1.17 [INFO] [stderr] Checking tokio-proto v0.1.1 [INFO] [stderr] Checking tokio-line v0.1.0 (https://github.com/tokio-rs/tokio-line#64faee60) [INFO] [stderr] Checking stubborn-sink v0.1.0 (/opt/rustwide/workdir) [INFO] [stdout] warning: unused `#[macro_use]` import [INFO] [stdout] --> tests/acceptance.rs:1:1 [INFO] [stdout] | [INFO] [stdout] 1 | #[macro_use] [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_imports)]` on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused imports: `QuickCheck`, `StdGen`, `TestResult` [INFO] [stdout] --> tests/acceptance.rs:4:29 [INFO] [stdout] | [INFO] [stdout] 4 | use quickcheck::{Arbitrary, QuickCheck, StdGen, TestResult, quickcheck}; [INFO] [stdout] | ^^^^^^^^^^ ^^^^^^ ^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `std::collections::HashMap` [INFO] [stdout] --> tests/acceptance.rs:5:5 [INFO] [stdout] | [INFO] [stdout] 5 | use std::collections::HashMap; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `Write` [INFO] [stdout] --> tests/acceptance.rs:7:21 [INFO] [stdout] | [INFO] [stdout] 7 | use std::io::{Read, Write}; [INFO] [stdout] | ^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `Path` [INFO] [stdout] --> tests/acceptance.rs:8:17 [INFO] [stdout] | [INFO] [stdout] 8 | use std::path::{Path, PathBuf}; [INFO] [stdout] | ^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: use of deprecated associated function `std::error::Error::description`: use the Display impl or to_string() [INFO] [stdout] --> tests/acceptance.rs:177:71 [INFO] [stdout] | [INFO] [stdout] 177 | Err(why) => panic!("couldn't read wc stdout: {}", why.description()), [INFO] [stdout] | ^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(deprecated)]` on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: use of deprecated associated function `std::error::Error::description`: use the Display impl or to_string() [INFO] [stdout] --> tests/acceptance.rs:209:71 [INFO] [stdout] | [INFO] [stdout] 209 | Err(why) => panic!("couldn't read wc stdout: {}", why.description()), [INFO] [stdout] | ^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: use of deprecated associated function `std::error::Error::description`: use the Display impl or to_string() [INFO] [stdout] --> tests/acceptance.rs:261:71 [INFO] [stdout] | [INFO] [stdout] 261 | Err(why) => panic!("couldn't read wc stdout: {}", why.description()), [INFO] [stdout] | ^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `futures::sync::mpsc::UnboundedSender` [INFO] [stdout] --> src/bin/fake-remote-server.rs:6:5 [INFO] [stdout] | [INFO] [stdout] 6 | use futures::sync::mpsc::UnboundedSender; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_imports)]` on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `Sink` [INFO] [stdout] --> src/bin/fake-remote-server.rs:7:23 [INFO] [stdout] | [INFO] [stdout] 7 | use futures::{Stream, Sink}; [INFO] [stdout] | ^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `futures::IntoFuture` [INFO] [stdout] --> src/bin/fake-remote-server.rs:8:5 [INFO] [stdout] | [INFO] [stdout] 8 | use futures::IntoFuture; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> tests/acceptance.rs:195:13 [INFO] [stdout] | [INFO] [stdout] 195 | for mut client_process in self.client_processes.iter_mut() { [INFO] [stdout] | ----^^^^^^^^^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_mut)]` on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused imports: `ErrorKind`, `self` [INFO] [stdout] --> src/bin/fake-remote-server.rs:9:15 [INFO] [stdout] | [INFO] [stdout] 9 | use std::io::{self, ErrorKind}; [INFO] [stdout] | ^^^^ ^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `tokio_core::reactor::Handle` [INFO] [stdout] --> src/bin/fake-remote-server.rs:12:5 [INFO] [stdout] | [INFO] [stdout] 12 | use tokio_core::reactor::Handle; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> tests/acceptance.rs:273:13 [INFO] [stdout] | [INFO] [stdout] 273 | let mut child = cmd.stdout(Stdio::piped()) [INFO] [stdout] | ----^^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: use of deprecated trait `tokio_core::io::Io`: moved to the `tokio-io` crate [INFO] [stdout] --> src/bin/fake-remote-server.rs:10:5 [INFO] [stdout] | [INFO] [stdout] 10 | use tokio_core::io::Io; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(deprecated)]` on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused `std::result::Result` that must be used [INFO] [stdout] --> tests/acceptance.rs:174:13 [INFO] [stdout] | [INFO] [stdout] 174 | child.kill(); [INFO] [stdout] | ^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_must_use)]` on by default [INFO] [stdout] = note: this `Result` may be an `Err` variant, which should be handled [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused `std::result::Result` that must be used [INFO] [stdout] --> tests/acceptance.rs:205:13 [INFO] [stdout] | [INFO] [stdout] 205 | child.kill(); [INFO] [stdout] | ^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: this `Result` may be an `Err` variant, which should be handled [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: use of deprecated associated function `tokio_core::io::Io::framed`: moved to the `tokio-io` crate [INFO] [stdout] --> src/bin/fake-remote-server.rs:27:32 [INFO] [stdout] | [INFO] [stdout] 27 | let transport = socket.framed(LineCodec); [INFO] [stdout] | ^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused `std::result::Result` that must be used [INFO] [stdout] --> tests/acceptance.rs:287:13 [INFO] [stdout] | [INFO] [stdout] 287 | child.kill(); [INFO] [stdout] | ^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: this `Result` may be an `Err` variant, which should be handled [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: 13 warnings emitted [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `futures::sync::mpsc::UnboundedSender` [INFO] [stdout] --> src/bin/fake-remote-server.rs:6:5 [INFO] [stdout] | [INFO] [stdout] 6 | use futures::sync::mpsc::UnboundedSender; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_imports)]` on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `Sink` [INFO] [stdout] --> src/bin/fake-remote-server.rs:7:23 [INFO] [stdout] | [INFO] [stdout] 7 | use futures::{Stream, Sink}; [INFO] [stdout] | ^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `futures::IntoFuture` [INFO] [stdout] --> src/bin/fake-remote-server.rs:8:5 [INFO] [stdout] | [INFO] [stdout] 8 | use futures::IntoFuture; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused imports: `ErrorKind`, `self` [INFO] [stdout] --> src/bin/fake-remote-server.rs:9:15 [INFO] [stdout] | [INFO] [stdout] 9 | use std::io::{self, ErrorKind}; [INFO] [stdout] | ^^^^ ^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `tokio_core::reactor::Handle` [INFO] [stdout] --> src/bin/fake-remote-server.rs:12:5 [INFO] [stdout] | [INFO] [stdout] 12 | use tokio_core::reactor::Handle; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: use of deprecated trait `tokio_core::io::Io`: moved to the `tokio-io` crate [INFO] [stdout] --> src/bin/fake-remote-server.rs:10:5 [INFO] [stdout] | [INFO] [stdout] 10 | use tokio_core::io::Io; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(deprecated)]` on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `str` [INFO] [stdout] --> src/stubborn_sink.rs:9:21 [INFO] [stdout] | [INFO] [stdout] 9 | use std::{self, io, str, fmt, thread, time}; [INFO] [stdout] | ^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_imports)]` on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused doc comment [INFO] [stdout] --> src/stubborn_sink.rs:57:9 [INFO] [stdout] | [INFO] [stdout] 57 | / /** [INFO] [stdout] 58 | | * This is the only method that I have found to stop sending messages to the remote server after [INFO] [stdout] 59 | | * it closed the connection, I don't like it, I would try to avoid the middleware_tx and [INFO] [stdout] 60 | | * the reader future: [INFO] [stdout] ... | [INFO] [stdout] 69 | | * - spawn the linked future [INFO] [stdout] 70 | | */ [INFO] [stdout] | |___________^ [INFO] [stdout] 71 | / let reader = receiver [INFO] [stdout] 72 | | .for_each(|_message| { [INFO] [stdout] 73 | | Ok(()) [INFO] [stdout] 74 | | }) [INFO] [stdout] ... | [INFO] [stdout] 78 | | Ok(()) [INFO] [stdout] 79 | | }); [INFO] [stdout] | |_______________- rustdoc does not generate documentation for statements [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_doc_comments)]` on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused doc comment [INFO] [stdout] --> src/stubborn_sink.rs:99:9 [INFO] [stdout] | [INFO] [stdout] 99 | / /** [INFO] [stdout] 100 | | * I need a loop to handle current state and also the next state, [INFO] [stdout] 101 | | * avoiding code duplication and recursion [INFO] [stdout] 102 | | */ [INFO] [stdout] | |___________^ [INFO] [stdout] 103 | / loop { [INFO] [stdout] 104 | | debug!("current status: {}", self.status); [INFO] [stdout] 105 | | [INFO] [stdout] 106 | | /** [INFO] [stdout] ... | [INFO] [stdout] 144 | | } [INFO] [stdout] 145 | | } [INFO] [stdout] | |_________- rustdoc does not generate documentation for expressions [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused doc comment [INFO] [stdout] --> src/stubborn_sink.rs:106:13 [INFO] [stdout] | [INFO] [stdout] 106 | / /** [INFO] [stdout] 107 | | * current status cannot be updated "on the fly" because the enum is in "use" [INFO] [stdout] 108 | | */ [INFO] [stdout] | |_______________^ [INFO] [stdout] 109 | / let next_status = match self.status { [INFO] [stdout] 110 | | RemoteConnectionState::Connected(ref split_sink) => { [INFO] [stdout] 111 | | match split_sink.send(msg.clone()) { [INFO] [stdout] 112 | | Ok(_) => return Ok(AsyncSink::Ready), [INFO] [stdout] ... | [INFO] [stdout] 138 | | } [INFO] [stdout] 139 | | }; [INFO] [stdout] | |______________- rustdoc does not generate documentation for statements [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused doc comment [INFO] [stdout] --> src/stubborn_sink.rs:119:29 [INFO] [stdout] | [INFO] [stdout] 119 | / ... /** [INFO] [stdout] 120 | | ... * If remote server is down, avoiding to "dos" it, [INFO] [stdout] 121 | | ... * waiting a reasonable amount of time between retries [INFO] [stdout] 122 | | ... */ [INFO] [stdout] | |_________________________^ [INFO] [stdout] 123 | ... thread::sleep(time::Duration::from_millis(100)); //TODO:! make millis configurable [INFO] [stdout] | ----------------------------------------------- rustdoc does not generate documentation for expressions [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `std::time::Duration` [INFO] [stdout] --> src/server.rs:5:5 [INFO] [stdout] | [INFO] [stdout] 5 | use std::time::Duration; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `tokio_timer::*` [INFO] [stdout] --> src/server.rs:12:5 [INFO] [stdout] | [INFO] [stdout] 12 | use tokio_timer::*; [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: trait objects without an explicit `dyn` are deprecated [INFO] [stdout] --> src/server.rs:30:43 [INFO] [stdout] | [INFO] [stdout] 30 | pub fn accept_connection(self) -> Box> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ help: use `dyn`: `dyn Future` [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(bare_trait_objects)]` on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused doc comment [INFO] [stdout] --> src/main.rs:37:5 [INFO] [stdout] | [INFO] [stdout] 37 | / /** [INFO] [stdout] 38 | | * every connected client receives a clone of buftx where to sends data [INFO] [stdout] 39 | | * all received data are read from bufrx and sent the StubbornSink which will try to [INFO] [stdout] 40 | | * sent it to the final destination. If the final destination is unreachable StubbornSink will [INFO] [stdout] 41 | | * returns a NotReady error and received data will remains in this channel [INFO] [stdout] 42 | | */ [INFO] [stdout] | |_______^ [INFO] [stdout] 43 | let (buftx, bufrx) = mpsc::unbounded(); [INFO] [stdout] | --------------------------------------- rustdoc does not generate documentation for statements [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused doc comment [INFO] [stdout] --> src/main.rs:51:5 [INFO] [stdout] | [INFO] [stdout] 51 | / /** [INFO] [stdout] 52 | | * sends all data received by clients to the remote server [INFO] [stdout] 53 | | */ [INFO] [stdout] | |_______^ [INFO] [stdout] 54 | / let forwarding = bufrx [INFO] [stdout] 55 | | .map_err(|_| io::Error::new(ErrorKind::Other, "should never happens")) [INFO] [stdout] 56 | | .forward(stubborn_sink); [INFO] [stdout] | |________________________________- rustdoc does not generate documentation for statements [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused doc comment [INFO] [stdout] --> src/main.rs:59:5 [INFO] [stdout] | [INFO] [stdout] 59 | / /** [INFO] [stdout] 60 | | * listening for client connections [INFO] [stdout] 61 | | */ [INFO] [stdout] | |_______^ [INFO] [stdout] 62 | let server = Server::new(configuration.clone(), handle.clone(), buftx.clone()); [INFO] [stdout] | ------------------------------------------------------------------------------- rustdoc does not generate documentation for statements [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: use of deprecated associated function `tokio_core::io::Io::framed`: moved to the `tokio-io` crate [INFO] [stdout] --> src/bin/fake-remote-server.rs:27:32 [INFO] [stdout] | [INFO] [stdout] 27 | let transport = socket.framed(LineCodec); [INFO] [stdout] | ^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: use of deprecated trait `tokio_core::io::Io`: moved to the `tokio-io` crate [INFO] [stdout] --> src/stubborn_sink.rs:5:5 [INFO] [stdout] | [INFO] [stdout] 5 | use tokio_core::io::Io; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(deprecated)]` on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: use of deprecated trait `tokio_core::io::Io`: moved to the `tokio-io` crate [INFO] [stdout] --> src/server.rs:8:5 [INFO] [stdout] | [INFO] [stdout] 8 | use tokio_core::io::Io; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused `std::result::Result` that must be used [INFO] [stdout] --> src/bin/fake-client.rs:23:25 [INFO] [stdout] | [INFO] [stdout] 23 | file.write_all((value.to_string() + "\n").as_bytes()); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_must_use)]` on by default [INFO] [stdout] = note: this `Result` may be an `Err` variant, which should be handled [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `LineCodec: Codec` is not satisfied [INFO] [stdout] --> src/bin/fake-remote-server.rs:27:39 [INFO] [stdout] | [INFO] [stdout] 27 | let transport = socket.framed(LineCodec); [INFO] [stdout] | ^^^^^^^^^ the trait `Codec` is not implemented for `LineCodec` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: 1 warning emitted [INFO] [stdout] [INFO] [stdout] [INFO] [stderr] error: could not compile `stubborn-sink` [INFO] [stdout] error[E0599]: no method named `for_each` found for struct `Framed` in the current scope [INFO] [stdout] --> src/bin/fake-remote-server.rs:28:44 [INFO] [stdout] | [INFO] [stdout] 28 | let process_connection = transport.for_each(move |line| { [INFO] [stdout] | ^^^^^^^^ method not found in `Framed` [INFO] [stdout] | [INFO] [stdout] ::: /opt/rustwide/cargo-home/registry/src/github.com-1ecc6299db9ec823/tokio-core-0.1.17/src/io/frame.rs:314:1 [INFO] [stdout] | [INFO] [stdout] 314 | pub struct Framed { [INFO] [stdout] | ----------------------- [INFO] [stdout] | | [INFO] [stdout] | doesn't satisfy `_: Iterator` [INFO] [stdout] | doesn't satisfy `_: Stream` [INFO] [stdout] | [INFO] [stdout] ::: /opt/rustwide/cargo-home/git/checkouts/tokio-line-16ebd24a37a186a1/64faee6/simple/src/lib.rs:54:1 [INFO] [stdout] | [INFO] [stdout] 54 | pub struct LineCodec; [INFO] [stdout] | --------------------- doesn't satisfy `LineCodec: Codec` [INFO] [stdout] | [INFO] [stdout] = note: the method `for_each` exists but the following trait bounds were not satisfied: [INFO] [stdout] `LineCodec: Codec` [INFO] [stdout] which is required by `Framed: Stream` [INFO] [stdout] `Framed: Stream` [INFO] [stdout] which is required by `&mut Framed: Stream` [INFO] [stdout] `Framed: Iterator` [INFO] [stdout] which is required by `&mut Framed: Iterator` [INFO] [stdout] [INFO] [stdout] [INFO] [stderr] [INFO] [stdout] warning: unused import: `futures::future::Future` [INFO] [stdout] --> src/bin/fake-remote-server.rs:5:5 [INFO] [stdout] | [INFO] [stdout] 5 | use futures::future::Future; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stderr] To learn more, run the command again with --verbose. [INFO] [stdout] error: aborting due to 2 previous errors; 8 warnings emitted [INFO] [stdout] [INFO] [stdout] [INFO] [stderr] warning: build failed, waiting for other jobs to finish... [INFO] [stdout] Some errors have detailed explanations: E0277, E0599. [INFO] [stdout] [INFO] [stdout] For more information about an error, try `rustc --explain E0277`. [INFO] [stdout] [INFO] [stdout] warning: unused `std::result::Result` that must be used [INFO] [stdout] --> src/bin/fake-client.rs:23:25 [INFO] [stdout] | [INFO] [stdout] 23 | file.write_all((value.to_string() + "\n").as_bytes()); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_must_use)]` on by default [INFO] [stdout] = note: this `Result` may be an `Err` variant, which should be handled [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `str` [INFO] [stdout] --> src/stubborn_sink.rs:9:21 [INFO] [stdout] | [INFO] [stdout] 9 | use std::{self, io, str, fmt, thread, time}; [INFO] [stdout] | ^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_imports)]` on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused doc comment [INFO] [stdout] --> src/stubborn_sink.rs:57:9 [INFO] [stdout] | [INFO] [stdout] 57 | / /** [INFO] [stdout] 58 | | * This is the only method that I have found to stop sending messages to the remote server after [INFO] [stdout] 59 | | * it closed the connection, I don't like it, I would try to avoid the middleware_tx and [INFO] [stdout] 60 | | * the reader future: [INFO] [stdout] ... | [INFO] [stdout] 69 | | * - spawn the linked future [INFO] [stdout] 70 | | */ [INFO] [stdout] | |___________^ [INFO] [stdout] 71 | / let reader = receiver [INFO] [stdout] 72 | | .for_each(|_message| { [INFO] [stdout] 73 | | Ok(()) [INFO] [stdout] 74 | | }) [INFO] [stdout] ... | [INFO] [stdout] 78 | | Ok(()) [INFO] [stdout] 79 | | }); [INFO] [stdout] | |_______________- rustdoc does not generate documentation for statements [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_doc_comments)]` on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused doc comment [INFO] [stdout] --> src/stubborn_sink.rs:99:9 [INFO] [stdout] | [INFO] [stdout] 99 | / /** [INFO] [stdout] 100 | | * I need a loop to handle current state and also the next state, [INFO] [stdout] 101 | | * avoiding code duplication and recursion [INFO] [stdout] 102 | | */ [INFO] [stdout] | |___________^ [INFO] [stdout] 103 | / loop { [INFO] [stdout] 104 | | debug!("current status: {}", self.status); [INFO] [stdout] 105 | | [INFO] [stdout] 106 | | /** [INFO] [stdout] ... | [INFO] [stdout] 144 | | } [INFO] [stdout] 145 | | } [INFO] [stdout] | |_________- rustdoc does not generate documentation for expressions [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused doc comment [INFO] [stdout] --> src/stubborn_sink.rs:106:13 [INFO] [stdout] | [INFO] [stdout] 106 | / /** [INFO] [stdout] 107 | | * current status cannot be updated "on the fly" because the enum is in "use" [INFO] [stdout] 108 | | */ [INFO] [stdout] | |_______________^ [INFO] [stdout] 109 | / let next_status = match self.status { [INFO] [stdout] 110 | | RemoteConnectionState::Connected(ref split_sink) => { [INFO] [stdout] 111 | | match split_sink.send(msg.clone()) { [INFO] [stdout] 112 | | Ok(_) => return Ok(AsyncSink::Ready), [INFO] [stdout] ... | [INFO] [stdout] 138 | | } [INFO] [stdout] 139 | | }; [INFO] [stdout] | |______________- rustdoc does not generate documentation for statements [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused doc comment [INFO] [stdout] --> src/stubborn_sink.rs:119:29 [INFO] [stdout] | [INFO] [stdout] 119 | / ... /** [INFO] [stdout] 120 | | ... * If remote server is down, avoiding to "dos" it, [INFO] [stdout] 121 | | ... * waiting a reasonable amount of time between retries [INFO] [stdout] 122 | | ... */ [INFO] [stdout] | |_________________________^ [INFO] [stdout] 123 | ... thread::sleep(time::Duration::from_millis(100)); //TODO:! make millis configurable [INFO] [stdout] | ----------------------------------------------- rustdoc does not generate documentation for expressions [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `std::time::Duration` [INFO] [stdout] --> src/server.rs:5:5 [INFO] [stdout] | [INFO] [stdout] 5 | use std::time::Duration; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `tokio_timer::*` [INFO] [stdout] --> src/server.rs:12:5 [INFO] [stdout] | [INFO] [stdout] 12 | use tokio_timer::*; [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: trait objects without an explicit `dyn` are deprecated [INFO] [stdout] --> src/server.rs:30:43 [INFO] [stdout] | [INFO] [stdout] 30 | pub fn accept_connection(self) -> Box> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ help: use `dyn`: `dyn Future` [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(bare_trait_objects)]` on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused doc comment [INFO] [stdout] --> src/main.rs:37:5 [INFO] [stdout] | [INFO] [stdout] 37 | / /** [INFO] [stdout] 38 | | * every connected client receives a clone of buftx where to sends data [INFO] [stdout] 39 | | * all received data are read from bufrx and sent the StubbornSink which will try to [INFO] [stdout] 40 | | * sent it to the final destination. If the final destination is unreachable StubbornSink will [INFO] [stdout] 41 | | * returns a NotReady error and received data will remains in this channel [INFO] [stdout] 42 | | */ [INFO] [stdout] | |_______^ [INFO] [stdout] 43 | let (buftx, bufrx) = mpsc::unbounded(); [INFO] [stdout] | --------------------------------------- rustdoc does not generate documentation for statements [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused doc comment [INFO] [stdout] --> src/main.rs:51:5 [INFO] [stdout] | [INFO] [stdout] 51 | / /** [INFO] [stdout] 52 | | * sends all data received by clients to the remote server [INFO] [stdout] 53 | | */ [INFO] [stdout] | |_______^ [INFO] [stdout] 54 | / let forwarding = bufrx [INFO] [stdout] 55 | | .map_err(|_| io::Error::new(ErrorKind::Other, "should never happens")) [INFO] [stdout] 56 | | .forward(stubborn_sink); [INFO] [stdout] | |________________________________- rustdoc does not generate documentation for statements [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused doc comment [INFO] [stdout] --> src/main.rs:59:5 [INFO] [stdout] | [INFO] [stdout] 59 | / /** [INFO] [stdout] 60 | | * listening for client connections [INFO] [stdout] 61 | | */ [INFO] [stdout] | |_______^ [INFO] [stdout] 62 | let server = Server::new(configuration.clone(), handle.clone(), buftx.clone()); [INFO] [stdout] | ------------------------------------------------------------------------------- rustdoc does not generate documentation for statements [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: 1 warning emitted [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: use of deprecated trait `tokio_core::io::Io`: moved to the `tokio-io` crate [INFO] [stdout] --> src/stubborn_sink.rs:5:5 [INFO] [stdout] | [INFO] [stdout] 5 | use tokio_core::io::Io; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(deprecated)]` on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: use of deprecated trait `tokio_core::io::Io`: moved to the `tokio-io` crate [INFO] [stdout] --> src/server.rs:8:5 [INFO] [stdout] | [INFO] [stdout] 8 | use tokio_core::io::Io; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0599]: no method named `unwrap` found for unit type `()` in the current scope [INFO] [stdout] --> src/main.rs:30:24 [INFO] [stdout] | [INFO] [stdout] 30 | env_logger::init().unwrap(); [INFO] [stdout] | ^^^^^^ method not found in `()` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `LineCodec: Codec` is not satisfied [INFO] [stdout] --> src/bin/fake-remote-server.rs:27:39 [INFO] [stdout] | [INFO] [stdout] 27 | let transport = socket.framed(LineCodec); [INFO] [stdout] | ^^^^^^^^^ the trait `Codec` is not implemented for `LineCodec` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: use of deprecated associated function `tokio_core::io::Io::framed`: moved to the `tokio-io` crate [INFO] [stdout] --> src/stubborn_sink.rs:55:41 [INFO] [stdout] | [INFO] [stdout] 55 | let (sender, receiver) = stream.framed(LineCodec).split(); [INFO] [stdout] | ^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0599]: no method named `for_each` found for struct `Framed` in the current scope [INFO] [stdout] --> src/bin/fake-remote-server.rs:28:44 [INFO] [stdout] | [INFO] [stdout] 28 | let process_connection = transport.for_each(move |line| { [INFO] [stdout] | ^^^^^^^^ method not found in `Framed` [INFO] [stdout] | [INFO] [stdout] ::: /opt/rustwide/cargo-home/registry/src/github.com-1ecc6299db9ec823/tokio-core-0.1.17/src/io/frame.rs:314:1 [INFO] [stdout] | [INFO] [stdout] 314 | pub struct Framed { [INFO] [stdout] | ----------------------- [INFO] [stdout] | | [INFO] [stdout] | doesn't satisfy `_: Iterator` [INFO] [stdout] | doesn't satisfy `_: Stream` [INFO] [stdout] | [INFO] [stdout] ::: /opt/rustwide/cargo-home/git/checkouts/tokio-line-16ebd24a37a186a1/64faee6/simple/src/lib.rs:54:1 [INFO] [stdout] | [INFO] [stdout] 54 | pub struct LineCodec; [INFO] [stdout] | --------------------- doesn't satisfy `LineCodec: Codec` [INFO] [stdout] | [INFO] [stdout] = note: the method `for_each` exists but the following trait bounds were not satisfied: [INFO] [stdout] `LineCodec: Codec` [INFO] [stdout] which is required by `Framed: Stream` [INFO] [stdout] `Framed: Stream` [INFO] [stdout] which is required by `&mut Framed: Stream` [INFO] [stdout] `Framed: Iterator` [INFO] [stdout] which is required by `&mut Framed: Iterator` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `futures::future::Future` [INFO] [stdout] --> src/bin/fake-remote-server.rs:5:5 [INFO] [stdout] | [INFO] [stdout] 5 | use futures::future::Future; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error: aborting due to 2 previous errors; 8 warnings emitted [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] Some errors have detailed explanations: E0277, E0599. [INFO] [stdout] [INFO] [stdout] For more information about an error, try `rustc --explain E0277`. [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `LineCodec: Codec` is not satisfied [INFO] [stdout] --> src/stubborn_sink.rs:55:48 [INFO] [stdout] | [INFO] [stdout] 55 | let (sender, receiver) = stream.framed(LineCodec).split(); [INFO] [stdout] | ^^^^^^^^^ the trait `Codec` is not implemented for `LineCodec` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0599]: no method named `split` found for struct `Framed` in the current scope [INFO] [stdout] --> src/stubborn_sink.rs:55:59 [INFO] [stdout] | [INFO] [stdout] 55 | let (sender, receiver) = stream.framed(LineCodec).split(); [INFO] [stdout] | ^^^^^ method not found in `Framed` [INFO] [stdout] | [INFO] [stdout] ::: /opt/rustwide/cargo-home/registry/src/github.com-1ecc6299db9ec823/tokio-core-0.1.17/src/io/frame.rs:314:1 [INFO] [stdout] | [INFO] [stdout] 314 | pub struct Framed { [INFO] [stdout] | ----------------------- doesn't satisfy `_: Stream` [INFO] [stdout] | [INFO] [stdout] ::: /opt/rustwide/cargo-home/git/checkouts/tokio-line-16ebd24a37a186a1/64faee6/simple/src/lib.rs:54:1 [INFO] [stdout] | [INFO] [stdout] 54 | pub struct LineCodec; [INFO] [stdout] | --------------------- doesn't satisfy `LineCodec: Codec` [INFO] [stdout] | [INFO] [stdout] = note: the method `split` exists but the following trait bounds were not satisfied: [INFO] [stdout] `LineCodec: Codec` [INFO] [stdout] which is required by `Framed: Stream` [INFO] [stdout] `Framed: Stream` [INFO] [stdout] which is required by `&mut Framed: Stream` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: use of deprecated associated function `futures::sync::mpsc::UnboundedSender::::send`: renamed to `unbounded_send` [INFO] [stdout] --> src/stubborn_sink.rs:111:38 [INFO] [stdout] | [INFO] [stdout] 111 | match split_sink.send(msg.clone()) { [INFO] [stdout] | ^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: use of deprecated associated function `tokio_core::io::Io::framed`: moved to the `tokio-io` crate [INFO] [stdout] --> src/server.rs:36:36 [INFO] [stdout] | [INFO] [stdout] 36 | let transport = socket.framed(LineCodec); [INFO] [stdout] | ^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `LineCodec: Codec` is not satisfied [INFO] [stdout] --> src/server.rs:36:43 [INFO] [stdout] | [INFO] [stdout] 36 | let transport = socket.framed(LineCodec); [INFO] [stdout] | ^^^^^^^^^ the trait `Codec` is not implemented for `LineCodec` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0599]: no method named `for_each` found for struct `Framed` in the current scope [INFO] [stdout] --> src/server.rs:39:48 [INFO] [stdout] | [INFO] [stdout] 39 | let process_connection = transport.for_each(move |line| { [INFO] [stdout] | ^^^^^^^^ method not found in `Framed` [INFO] [stdout] | [INFO] [stdout] ::: /opt/rustwide/cargo-home/registry/src/github.com-1ecc6299db9ec823/tokio-core-0.1.17/src/io/frame.rs:314:1 [INFO] [stdout] | [INFO] [stdout] 314 | pub struct Framed { [INFO] [stdout] | ----------------------- [INFO] [stdout] | | [INFO] [stdout] | doesn't satisfy `_: Iterator` [INFO] [stdout] | doesn't satisfy `_: Stream` [INFO] [stdout] | [INFO] [stdout] ::: /opt/rustwide/cargo-home/git/checkouts/tokio-line-16ebd24a37a186a1/64faee6/simple/src/lib.rs:54:1 [INFO] [stdout] | [INFO] [stdout] 54 | pub struct LineCodec; [INFO] [stdout] | --------------------- doesn't satisfy `LineCodec: Codec` [INFO] [stdout] | [INFO] [stdout] = note: the method `for_each` exists but the following trait bounds were not satisfied: [INFO] [stdout] `LineCodec: Codec` [INFO] [stdout] which is required by `Framed: Stream` [INFO] [stdout] `Framed: Stream` [INFO] [stdout] which is required by `&mut Framed: Stream` [INFO] [stdout] `Framed: Iterator` [INFO] [stdout] which is required by `&mut Framed: Iterator` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error: aborting due to 5 previous errors; 16 warnings emitted [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] Some errors have detailed explanations: E0277, E0599. [INFO] [stdout] [INFO] [stdout] For more information about an error, try `rustc --explain E0277`. [INFO] [stdout] [INFO] [stdout] error[E0599]: no method named `unwrap` found for unit type `()` in the current scope [INFO] [stdout] --> src/main.rs:30:24 [INFO] [stdout] | [INFO] [stdout] 30 | env_logger::init().unwrap(); [INFO] [stdout] | ^^^^^^ method not found in `()` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: use of deprecated associated function `tokio_core::io::Io::framed`: moved to the `tokio-io` crate [INFO] [stdout] --> src/stubborn_sink.rs:55:41 [INFO] [stdout] | [INFO] [stdout] 55 | let (sender, receiver) = stream.framed(LineCodec).split(); [INFO] [stdout] | ^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `LineCodec: Codec` is not satisfied [INFO] [stdout] --> src/stubborn_sink.rs:55:48 [INFO] [stdout] | [INFO] [stdout] 55 | let (sender, receiver) = stream.framed(LineCodec).split(); [INFO] [stdout] | ^^^^^^^^^ the trait `Codec` is not implemented for `LineCodec` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0599]: no method named `split` found for struct `Framed` in the current scope [INFO] [stdout] --> src/stubborn_sink.rs:55:59 [INFO] [stdout] | [INFO] [stdout] 55 | let (sender, receiver) = stream.framed(LineCodec).split(); [INFO] [stdout] | ^^^^^ method not found in `Framed` [INFO] [stdout] | [INFO] [stdout] ::: /opt/rustwide/cargo-home/registry/src/github.com-1ecc6299db9ec823/tokio-core-0.1.17/src/io/frame.rs:314:1 [INFO] [stdout] | [INFO] [stdout] 314 | pub struct Framed { [INFO] [stdout] | ----------------------- doesn't satisfy `_: Stream` [INFO] [stdout] | [INFO] [stdout] ::: /opt/rustwide/cargo-home/git/checkouts/tokio-line-16ebd24a37a186a1/64faee6/simple/src/lib.rs:54:1 [INFO] [stdout] | [INFO] [stdout] 54 | pub struct LineCodec; [INFO] [stdout] | --------------------- doesn't satisfy `LineCodec: Codec` [INFO] [stdout] | [INFO] [stdout] = note: the method `split` exists but the following trait bounds were not satisfied: [INFO] [stdout] `LineCodec: Codec` [INFO] [stdout] which is required by `Framed: Stream` [INFO] [stdout] `Framed: Stream` [INFO] [stdout] which is required by `&mut Framed: Stream` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: use of deprecated associated function `futures::sync::mpsc::UnboundedSender::::send`: renamed to `unbounded_send` [INFO] [stdout] --> src/stubborn_sink.rs:111:38 [INFO] [stdout] | [INFO] [stdout] 111 | match split_sink.send(msg.clone()) { [INFO] [stdout] | ^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: use of deprecated associated function `tokio_core::io::Io::framed`: moved to the `tokio-io` crate [INFO] [stdout] --> src/server.rs:36:36 [INFO] [stdout] | [INFO] [stdout] 36 | let transport = socket.framed(LineCodec); [INFO] [stdout] | ^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `LineCodec: Codec` is not satisfied [INFO] [stdout] --> src/server.rs:36:43 [INFO] [stdout] | [INFO] [stdout] 36 | let transport = socket.framed(LineCodec); [INFO] [stdout] | ^^^^^^^^^ the trait `Codec` is not implemented for `LineCodec` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0599]: no method named `for_each` found for struct `Framed` in the current scope [INFO] [stdout] --> src/server.rs:39:48 [INFO] [stdout] | [INFO] [stdout] 39 | let process_connection = transport.for_each(move |line| { [INFO] [stdout] | ^^^^^^^^ method not found in `Framed` [INFO] [stdout] | [INFO] [stdout] ::: /opt/rustwide/cargo-home/registry/src/github.com-1ecc6299db9ec823/tokio-core-0.1.17/src/io/frame.rs:314:1 [INFO] [stdout] | [INFO] [stdout] 314 | pub struct Framed { [INFO] [stdout] | ----------------------- [INFO] [stdout] | | [INFO] [stdout] | doesn't satisfy `_: Iterator` [INFO] [stdout] | doesn't satisfy `_: Stream` [INFO] [stdout] | [INFO] [stdout] ::: /opt/rustwide/cargo-home/git/checkouts/tokio-line-16ebd24a37a186a1/64faee6/simple/src/lib.rs:54:1 [INFO] [stdout] | [INFO] [stdout] 54 | pub struct LineCodec; [INFO] [stdout] | --------------------- doesn't satisfy `LineCodec: Codec` [INFO] [stdout] | [INFO] [stdout] = note: the method `for_each` exists but the following trait bounds were not satisfied: [INFO] [stdout] `LineCodec: Codec` [INFO] [stdout] which is required by `Framed: Stream` [INFO] [stdout] `Framed: Stream` [INFO] [stdout] which is required by `&mut Framed: Stream` [INFO] [stdout] `Framed: Iterator` [INFO] [stdout] which is required by `&mut Framed: Iterator` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error: aborting due to 5 previous errors; 16 warnings emitted [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] Some errors have detailed explanations: E0277, E0599. [INFO] [stdout] [INFO] [stdout] For more information about an error, try `rustc --explain E0277`. [INFO] [stdout] [INFO] [stderr] error: build failed [INFO] running `Command { std: "docker" "inspect" "f9d70b12ac5dd19f7062b706bfdc9e9cf75ac03b68029cad5bb239ace1084a4f", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "f9d70b12ac5dd19f7062b706bfdc9e9cf75ac03b68029cad5bb239ace1084a4f", kill_on_drop: false }` [INFO] [stdout] f9d70b12ac5dd19f7062b706bfdc9e9cf75ac03b68029cad5bb239ace1084a4f