trivial-type-errors.rs

fortysix@electryon:sirpent-rust ∴ cargo run
   Compiling sirpent v0.1.1 (file:///Users/fortysix/forest/sirpent-team/sirpent-rust)
error[E0277]: the trait bound `futures::stream::Iter<std::iter::Map<std::iter::Filter<std::vec::IntoIter<comms::Client<std::string::String, tokio_io::codec::Framed<tokio_core::net::TcpStream, sirpent::net::MsgCodec>>>, fn(&comms::Client<std::string::String, tokio_io::codec::Framed<tokio_core::net::TcpStream, sirpent::net::MsgCodec>>) -> bool {<comms::Client<I, C>><std::string::String, tokio_io::codec::Framed<tokio_core::net::TcpStream, sirpent::net::MsgCodec>>::is_connected}>, fn(comms::Client<std::string::String, tokio_io::codec::Framed<tokio_core::net::TcpStream, sirpent::net::MsgCodec>>) -> std::result::Result<comms::Client<std::string::String, tokio_io::codec::Framed<tokio_core::net::TcpStream, sirpent::net::MsgCodec>>, _> {std::result::Result<comms::Client<std::string::String, tokio_io::codec::Framed<tokio_core::net::TcpStream, sirpent::net::MsgCodec>>, _>::Ok}>>: futures::Future` is not satisfied
  --> src/main.rs:94:23
   |
94 |                      .and_then(|(game, players)| {
   |                       ^^^^^^^^ the trait `futures::Future` is not implemented for `futures::stream::Iter<std::iter::Map<std::iter::Filter<std::vec::IntoIter<comms::Client<std::string::String, tokio_io::codec::Framed<tokio_core::net::TcpStream, sirpent::net::MsgCodec>>>, fn(&comms::Client<std::string::String, tokio_io::codec::Framed<tokio_core::net::TcpStream, sirpent::net::MsgCodec>>) -> bool {<comms::Client<I, C>><std::string::String, tokio_io::codec::Framed<tokio_core::net::TcpStream, sirpent::net::MsgCodec>>::is_connected}>, fn(comms::Client<std::string::String, tokio_io::codec::Framed<tokio_core::net::TcpStream, sirpent::net::MsgCodec>>) -> std::result::Result<comms::Client<std::string::String, tokio_io::codec::Framed<tokio_core::net::TcpStream, sirpent::net::MsgCodec>>, _> {std::result::Result<comms::Client<std::string::String, tokio_io::codec::Framed<tokio_core::net::TcpStream, sirpent::net::MsgCodec>>, _>::Ok}>>`
   |
   = note: required because of the requirements on the impl of `futures::IntoFuture` for `futures::stream::Iter<std::iter::Map<std::iter::Filter<std::vec::IntoIter<comms::Client<std::string::String, tokio_io::codec::Framed<tokio_core::net::TcpStream, sirpent::net::MsgCodec>>>, fn(&comms::Client<std::string::String, tokio_io::codec::Framed<tokio_core::net::TcpStream, sirpent::net::MsgCodec>>) -> bool {<comms::Client<I, C>><std::string::String, tokio_io::codec::Framed<tokio_core::net::TcpStream, sirpent::net::MsgCodec>>::is_connected}>, fn(comms::Client<std::string::String, tokio_io::codec::Framed<tokio_core::net::TcpStream, sirpent::net::MsgCodec>>) -> std::result::Result<comms::Client<std::string::String, tokio_io::codec::Framed<tokio_core::net::TcpStream, sirpent::net::MsgCodec>>, _> {std::result::Result<comms::Client<std::string::String, tokio_io::codec::Framed<tokio_core::net::TcpStream, sirpent::net::MsgCodec>>, _>::Ok}>>`

error: no method named `flatten_stream` found for type `futures::stream::AndThen<futures::stream::AndThen<futures::stream::Map<futures::stream::Chunks<futures::sync::mpsc::Receiver<comms::Client<std::string::String, tokio_io::codec::Framed<tokio_core::net::TcpStream, sirpent::net::MsgCodec>>>>, [closure@src/main.rs:92:27: 92:85]>, [closure@src/main.rs:93:32: 93:77 game_server_actor_ref:_], kabuki::ActorFuture<comms::Room<std::string::String, tokio_io::codec::Framed<tokio_core::net::TcpStream, sirpent::net::MsgCodec>>, (sirpent::engine::Game, comms::Room<std::string::String, tokio_io::codec::Framed<tokio_core::net::TcpStream, sirpent::net::MsgCodec>>), ()>>, [closure@src/main.rs:94:32: 99:14], futures::stream::Iter<std::iter::Map<std::iter::Filter<std::vec::IntoIter<comms::Client<std::string::String, tokio_io::codec::Framed<tokio_core::net::TcpStream, sirpent::net::MsgCodec>>>, fn(&comms::Client<std::string::String, tokio_io::codec::Framed<tokio_core::net::TcpStream, sirpent::net::MsgCodec>>) -> bool {<comms::Client<I, C>><std::string::String, tokio_io::codec::Framed<tokio_core::net::TcpStream, sirpent::net::MsgCodec>>::is_connected}>, fn(comms::Client<std::string::String, tokio_io::codec::Framed<tokio_core::net::TcpStream, sirpent::net::MsgCodec>>) -> std::result::Result<comms::Client<std::string::String, tokio_io::codec::Framed<tokio_core::net::TcpStream, sirpent::net::MsgCodec>>, _> {std::result::Result<comms::Client<std::string::String, tokio_io::codec::Framed<tokio_core::net::TcpStream, sirpent::net::MsgCodec>>, _>::Ok}>>>` in the current scope
   --> src/main.rs:100:23
    |
100 |                      .flatten_stream()
    |                       ^^^^^^^^^^^^^^
    |
    = note: the method `flatten_stream` exists but the following trait bounds were not satisfied: `futures::stream::AndThen<futures::stream::AndThen<futures::stream::Map<futures::stream::Chunks<futures::sync::mpsc::Receiver<comms::Client<std::string::String, tokio_io::codec::Framed<tokio_core::net::TcpStream, sirpent::net::MsgCodec>>>>, [closure@src/main.rs:92:27: 92:85]>, [closure@src/main.rs:93:32: 93:77 game_server_actor_ref:_], kabuki::ActorFuture<comms::Room<std::string::String, tokio_io::codec::Framed<tokio_core::net::TcpStream, sirpent::net::MsgCodec>>, (sirpent::engine::Game, comms::Room<std::string::String, tokio_io::codec::Framed<tokio_core::net::TcpStream, sirpent::net::MsgCodec>>), ()>>, [closure@src/main.rs:94:32: 99:14], futures::stream::Iter<std::iter::Map<std::iter::Filter<std::vec::IntoIter<comms::Client<std::string::String, tokio_io::codec::Framed<tokio_core::net::TcpStream, sirpent::net::MsgCodec>>>, fn(&comms::Client<std::string::String, tokio_io::codec::Framed<tokio_core::net::TcpStream, sirpent::net::MsgCodec>>) -> bool {<comms::Client<I, C>><std::string::String, tokio_io::codec::Framed<tokio_core::net::TcpStream, sirpent::net::MsgCodec>>::is_connected}>, fn(comms::Client<std::string::String, tokio_io::codec::Framed<tokio_core::net::TcpStream, sirpent::net::MsgCodec>>) -> std::result::Result<comms::Client<std::string::String, tokio_io::codec::Framed<tokio_core::net::TcpStream, sirpent::net::MsgCodec>>, _> {std::result::Result<comms::Client<std::string::String, tokio_io::codec::Framed<tokio_core::net::TcpStream, sirpent::net::MsgCodec>>, _>::Ok}>>> : futures::Future`

error: aborting due to 2 previous errors