Created
December 13, 2019 20:48
-
-
Save benesch/34e8374d07077ed0e8dedb4095cbf427 to your computer and use it in GitHub Desktop.
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| benesch@langur$ cargo check | |
| Checking pgwire v0.1.0 (/Users/benesch/Sites/materialize/materialize/src/pgwire) | |
| warning: unused imports: `Future`, `future` | |
| --> src/pgwire/lib.rs:21:15 | |
| | | |
| 21 | use futures::{future, Future}; | |
| | ^^^^^^ ^^^^^^ | |
| | | |
| = note: `#[warn(unused_imports)]` on by default | |
| warning: unused import: `ore::future::OreFutureExt` | |
| --> src/pgwire/lib.rs:26:5 | |
| | | |
| 26 | use ore::future::OreFutureExt; | |
| | ^^^^^^^^^^^^^^^^^^^^^^^^^ | |
| warning: unused import: `TryStreamExt` | |
| --> src/pgwire/protocol.rs:10:48 | |
| | | |
| 10 | use futures::stream::{self, Stream, StreamExt, TryStreamExt}; | |
| | ^^^^^^^^^^^^ | |
| warning: unreachable pattern | |
| --> src/pgwire/protocol.rs:289:17 | |
| | | |
| 289 | ExecuteResponse::CreatedIndex => conn.send(command_complete("CREATE INDEX")).await?, | |
| | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ | |
| | | |
| = note: `#[warn(unreachable_patterns)]` on by default | |
| warning: irrefutable while-let pattern | |
| --> src/pgwire/protocol.rs:357:9 | |
| | | |
| 357 | / while let msg = conn.try_recv().await? { | |
| 358 | | if let FrontendMessage::Sync = msg { | |
| 359 | | break; | |
| 360 | | } | |
| 361 | | } | |
| | |_________^ | |
| | | |
| = note: `#[warn(irrefutable_let_patterns)]` on by default | |
| warning: unused variable: `row_desc` | |
| --> src/pgwire/protocol.rs:240:21 | |
| | | |
| 240 | let row_desc = stmt.desc().cloned(); | |
| | ^^^^^^^^ help: consider prefixing with an underscore: `_row_desc` | |
| | | |
| = note: `#[warn(unused_variables)]` on by default | |
| warning: unused variable: `err` | |
| --> src/pgwire/protocol.rs:264:25 | |
| | | |
| 264 | result: Err(err), | |
| | ^^^ help: consider prefixing with an underscore: `_err` | |
| warning: unused variable: `session` | |
| --> src/pgwire/protocol.rs:265:17 | |
| | | |
| 265 | mut session, | |
| | ----^^^^^^^ | |
| | | | |
| | help: try ignoring the field: `session: _` | |
| warning: unused variable: `cx` | |
| --> src/pgwire/protocol.rs:272:5 | |
| | | |
| 272 | cx: &mut Context, | |
| | ^^ help: consider prefixing with an underscore: `_cx` | |
| warning: variable does not need to be mutable | |
| --> src/pgwire/protocol.rs:265:13 | |
| | | |
| 265 | mut session, | |
| | ----^^^^^^^ | |
| | | | |
| | help: remove this `mut` | |
| | | |
| = note: `#[warn(unused_mut)]` on by default | |
| warning: function is never used: `field_values_from_row` | |
| --> src/pgwire/message.rs:611:1 | |
| | | |
| 611 | pub fn field_values_from_row(row: Row, typ: &RelationType) -> Vec<Option<FieldValue>> { | |
| | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ | |
| | | |
| = note: `#[warn(dead_code)]` on by default | |
| warning: function is never used: `row_description_from_desc` | |
| --> src/pgwire/message.rs:618:1 | |
| | | |
| 618 | pub fn row_description_from_desc(desc: &RelationDesc) -> Vec<FieldDescription> { | |
| | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ | |
| warning: unused `std::result::Result` that must be used | |
| --> src/pgwire/protocol.rs:248:17 | |
| | | |
| 248 | / cx.cmdq_tx | |
| 249 | | .send(coord::Command::Execute { | |
| 250 | | portal_name: portal_name.clone(), | |
| 251 | | session, | |
| ... | | |
| 254 | | }) | |
| 255 | | .await; | |
| | |___________________________^ | |
| | | |
| = note: `#[warn(unused_must_use)]` on by default | |
| = note: this `Result` may be an `Err` variant, which should be handled | |
| Checking materialized v0.1.0 (/Users/benesch/Sites/materialize/materialize/src/materialized) | |
| error[E0277]: `*mut (dyn std::ops::Fn() + 'static)` cannot be shared between threads safely | |
| --> src/materialized/lib.rs:192:25 | |
| | | |
| 192 | tokio::spawn(handle_connection( | |
| | ^^^^^^^^^^^^ `*mut (dyn std::ops::Fn() + 'static)` cannot be shared between threads safely | |
| | | |
| ::: /Users/benesch/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-0.2.4/src/task/spawn.rs:123:21 | |
| | | |
| 123 | T: Future + Send + 'static, | |
| | ---- required by this bound in `tokio::task::spawn::spawn` | |
| | | |
| = help: within `core::fmt::Void`, the trait `std::marker::Sync` is not implemented for `*mut (dyn std::ops::Fn() + 'static)` | |
| = note: required because it appears within the type `std::marker::PhantomData<*mut (dyn std::ops::Fn() + 'static)>` | |
| = note: required because it appears within the type `core::fmt::Void` | |
| = note: required because of the requirements on the impl of `std::marker::Send` for `&core::fmt::Void` | |
| = note: required because it appears within the type `std::fmt::ArgumentV1<'_>` | |
| = note: required because it appears within the type `[std::fmt::ArgumentV1<'_>; 1]` | |
| = note: required because it appears within the type `for<'r, 's, 't0, 't1, 't2, 't3, 't4, 't5, 't6, 't7, 't8, 't9, 't10, 't11, 't12, 't13, 't14, 't15, 't16, 't17, 't18, 't19, 't20, 't21, 't22, 't23, 't24, 't25, 't26, 't27, 't28, 't29, 't30, 't31, 't32, 't33, 't34, 't35, 't36, 't37, 't38, 't39, 't40, 't41, 't42, 't43, 't44, 't45, 't46, 't47, 't48, 't49, 't50, 't51, 't52, 't53, 't54, 't55, 't56, 't57, 't58, 't59, 't60, 't61> {&'r mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'s mut pgwire::protocol::Context, futures_channel::oneshot::Receiver<coord::command::Response<coord::command::ExecuteResponse>>, pgwire::protocol::Flow, fn(std::result::Result<coord::command::Response<coord::command::ExecuteResponse>, futures_channel::oneshot::Canceled>) -> std::result::Result<<std::result::Result<coord::command::Response<coord::command::ExecuteResponse>, futures_channel::oneshot::Canceled> as std::ops::Try>::Ok, <std::result::Result<coord::command::Response<coord::command::ExecuteResponse>, futures_channel::oneshot::Canceled> as std::ops::Try>::Error> {<std::result::Result<coord::command::Response<coord::command::ExecuteResponse>, futures_channel::oneshot::Canceled> as std::ops::Try>::into_result}, futures_channel::oneshot::Receiver<coord::command::Response<coord::command::ExecuteResponse>>, futures_channel::oneshot::Receiver<coord::command::Response<coord::command::ExecuteResponse>>, (), std::result::Result<coord::command::Response<coord::command::ExecuteResponse>, futures_channel::oneshot::Canceled>, std::result::Result<coord::command::Response<coord::command::ExecuteResponse>, futures_channel::oneshot::Canceled>, coord::command::Response<coord::command::ExecuteResponse>, coord::command::ExecuteResponse, sql::session::session::Session, coord::command::ExecuteResponse, fn(std::result::Result<(), std::io::Error>) -> std::result::Result<<std::result::Result<(), std::io::Error> as std::ops::Try>::Ok, <std::result::Result<(), std::io::Error> as std::ops::Try>::Error> {<std::result::Result<(), std::io::Error> as std::ops::Try>::into_result}, &'t0 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'t1 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, fn(&'t2 str) -> pgwire::message::BackendMessage {pgwire::protocol::handle_query::{{closure}}#0::command_complete::<&'t2 str>}, &'t3 str, pgwire::message::BackendMessage, futures_util::sink::send::Send<'t4, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, futures_util::sink::send::Send<'t5, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, (), fn(std::result::Result<(), std::io::Error>) -> std::result::Result<<std::result::Result<(), std::io::Error> as std::ops::Try>::Ok, <std::result::Result<(), std::io::Error> as std::ops::Try>::Error> {<std::result::Result<(), std::io::Error> as std::ops::Try>::into_result}, &'t6 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'t7 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, fn(&'t8 str) -> pgwire::message::BackendMessage {pgwire::protocol::handle_query::{{closure}}#0::command_complete::<&'t8 str>}, &'t9 str, pgwire::message::BackendMessage, futures_util::sink::send::Send<'t10, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, futures_util::sink::send::Send<'t11, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, (), fn(std::result::Result<(), std::io::Error>) -> std::result::Result<<std::result::Result<(), std::io::Error> as std::ops::Try>::Ok, <std::result::Result<(), std::io::Error> as std::ops::Try>::Error> {<std::result::Result<(), std::io::Error> as std::ops::Try>::into_result}, &'t12 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'t13 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, fn(&'t14 str) -> pgwire::message::BackendMessage {pgwire::protocol::handle_query::{{closure}}#0::command_complete::<&'t14 str>}, &'t15 str, pgwire::message::BackendMessage, futures_util::sink::send::Send<'t16, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, futures_util::sink::send::Send<'t17, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, (), fn(std::result::Result<(), std::io::Error>) -> std::result::Result<<std::result::Result<(), std::io::Error> as std::ops::Try>::Ok, <std::result::Result<(), std::io::Error> as std::ops::Try>::Error> {<std::result::Result<(), std::io::Error> as std::ops::Try>::into_result}, &'t18 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'t19 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, fn(&'t20 str) -> pgwire::message::BackendMessage {pgwire::protocol::handle_query::{{closure}}#0::command_complete::<&'t20 str>}, &'t21 str, pgwire::message::BackendMessage, futures_util::sink::send::Send<'t22, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, futures_util::sink::send::Send<'t23, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, (), fn(std::result::Result<(), std::io::Error>) -> std::result::Result<<std::result::Result<(), std::io::Error> as std::ops::Try>::Ok, <std::result::Result<(), std::io::Error> as std::ops::Try>::Error> {<std::result::Result<(), std::io::Error> as std::ops::Try>::into_result}, &'t24 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'t25 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, fn(&'t26 str) -> pgwire::message::BackendMessage {pgwire::protocol::handle_query::{{closure}}#0::command_complete::<&'t26 str>}, &'t27 str, pgwire::message::BackendMessage, futures_util::sink::send::Send<'t28, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, futures_util::sink::send::Send<'t29, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, (), fn(std::result::Result<(), std::io::Error>) -> std::result::Result<<std::result::Result<(), std::io::Error> as std::ops::Try>::Ok, <std::result::Result<(), std::io::Error> as std::ops::Try>::Error> {<std::result::Result<(), std::io::Error> as std::ops::Try>::into_result}, &'t30 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'t31 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, fn(&'t32 str) -> pgwire::message::BackendMessage {pgwire::protocol::handle_query::{{closure}}#0::command_complete::<&'t32 str>}, &'t33 str, pgwire::message::BackendMessage, futures_util::sink::send::Send<'t34, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, futures_util::sink::send::Send<'t35, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, (), usize, fn(std::result::Result<(), std::io::Error>) -> std::result::Result<<std::result::Result<(), std::io::Error> as std::ops::Try>::Ok, <std::result::Result<(), std::io::Error> as std::ops::Try>::Error> {<std::result::Result<(), std::io::Error> as std::ops::Try>::into_result}, &'t36 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'t37 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, fn(std::string::String) -> pgwire::message::BackendMessage {pgwire::protocol::handle_query::{{closure}}#0::command_complete::<std::string::String>}, for<'t62> fn(std::fmt::Arguments<'t62>) -> std::string::String {std::fmt::format}, fn(&'t38 [&'t38 str], &'t38 [std::fmt::ArgumentV1<'t38>]) -> std::fmt::Arguments<'t38> {std::fmt::Arguments::<'t38>::new_v1}, &'t39 str, &'t40 str, [&'t41 str; 1], &'t42 [&'t43 str], &'t44 [&'t45 str; 1], usize, &'t46 usize, (&'t47 usize,), [std::fmt::ArgumentV1<'t48>; 1], &'t49 [std::fmt::ArgumentV1<'t50>], &'t51 [std::fmt::ArgumentV1<'t52>; 1], std::fmt::Arguments<'t53>, std::string::String, pgwire::message::BackendMessage, futures_util::sink::send::Send<'t54, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, futures_util::sink::send::Send<'t55, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, (), failure::error::Error, sql::session::session::Session, for<'_> fn(&mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, sql::session::session::Session, pgwire::protocol::Flow, &'static str, std::string::String) -> impl core::future::future::Future {pgwire::protocol::send_error::<tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, std::string::String>}, &'t56 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'t57 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, sql::session::session::Session, pgwire::protocol::Flow, &'t58 str, &'t59 failure::error::Error, failure::error::Error, std::string::String, impl core::future::future::Future, impl core::future::future::Future, ()}` | |
| = note: required because it appears within the type `[static generator@DefId(275:266 ~ pgwire[22ad]::protocol[0]::handle_query[0]::{{closure}}[0]) 0:&mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, 1:&mut pgwire::protocol::Context, 2:futures_channel::oneshot::Receiver<coord::command::Response<coord::command::ExecuteResponse>>, 3:pgwire::protocol::Flow for<'r, 's, 't0, 't1, 't2, 't3, 't4, 't5, 't6, 't7, 't8, 't9, 't10, 't11, 't12, 't13, 't14, 't15, 't16, 't17, 't18, 't19, 't20, 't21, 't22, 't23, 't24, 't25, 't26, 't27, 't28, 't29, 't30, 't31, 't32, 't33, 't34, 't35, 't36, 't37, 't38, 't39, 't40, 't41, 't42, 't43, 't44, 't45, 't46, 't47, 't48, 't49, 't50, 't51, 't52, 't53, 't54, 't55, 't56, 't57, 't58, 't59, 't60, 't61> {&'r mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'s mut pgwire::protocol::Context, futures_channel::oneshot::Receiver<coord::command::Response<coord::command::ExecuteResponse>>, pgwire::protocol::Flow, fn(std::result::Result<coord::command::Response<coord::command::ExecuteResponse>, futures_channel::oneshot::Canceled>) -> std::result::Result<<std::result::Result<coord::command::Response<coord::command::ExecuteResponse>, futures_channel::oneshot::Canceled> as std::ops::Try>::Ok, <std::result::Result<coord::command::Response<coord::command::ExecuteResponse>, futures_channel::oneshot::Canceled> as std::ops::Try>::Error> {<std::result::Result<coord::command::Response<coord::command::ExecuteResponse>, futures_channel::oneshot::Canceled> as std::ops::Try>::into_result}, futures_channel::oneshot::Receiver<coord::command::Response<coord::command::ExecuteResponse>>, futures_channel::oneshot::Receiver<coord::command::Response<coord::command::ExecuteResponse>>, (), std::result::Result<coord::command::Response<coord::command::ExecuteResponse>, futures_channel::oneshot::Canceled>, std::result::Result<coord::command::Response<coord::command::ExecuteResponse>, futures_channel::oneshot::Canceled>, coord::command::Response<coord::command::ExecuteResponse>, coord::command::ExecuteResponse, sql::session::session::Session, coord::command::ExecuteResponse, fn(std::result::Result<(), std::io::Error>) -> std::result::Result<<std::result::Result<(), std::io::Error> as std::ops::Try>::Ok, <std::result::Result<(), std::io::Error> as std::ops::Try>::Error> {<std::result::Result<(), std::io::Error> as std::ops::Try>::into_result}, &'t0 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'t1 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, fn(&'t2 str) -> pgwire::message::BackendMessage {pgwire::protocol::handle_query::{{closure}}#0::command_complete::<&'t2 str>}, &'t3 str, pgwire::message::BackendMessage, futures_util::sink::send::Send<'t4, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, futures_util::sink::send::Send<'t5, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, (), fn(std::result::Result<(), std::io::Error>) -> std::result::Result<<std::result::Result<(), std::io::Error> as std::ops::Try>::Ok, <std::result::Result<(), std::io::Error> as std::ops::Try>::Error> {<std::result::Result<(), std::io::Error> as std::ops::Try>::into_result}, &'t6 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'t7 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, fn(&'t8 str) -> pgwire::message::BackendMessage {pgwire::protocol::handle_query::{{closure}}#0::command_complete::<&'t8 str>}, &'t9 str, pgwire::message::BackendMessage, futures_util::sink::send::Send<'t10, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, futures_util::sink::send::Send<'t11, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, (), fn(std::result::Result<(), std::io::Error>) -> std::result::Result<<std::result::Result<(), std::io::Error> as std::ops::Try>::Ok, <std::result::Result<(), std::io::Error> as std::ops::Try>::Error> {<std::result::Result<(), std::io::Error> as std::ops::Try>::into_result}, &'t12 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'t13 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, fn(&'t14 str) -> pgwire::message::BackendMessage {pgwire::protocol::handle_query::{{closure}}#0::command_complete::<&'t14 str>}, &'t15 str, pgwire::message::BackendMessage, futures_util::sink::send::Send<'t16, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, futures_util::sink::send::Send<'t17, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, (), fn(std::result::Result<(), std::io::Error>) -> std::result::Result<<std::result::Result<(), std::io::Error> as std::ops::Try>::Ok, <std::result::Result<(), std::io::Error> as std::ops::Try>::Error> {<std::result::Result<(), std::io::Error> as std::ops::Try>::into_result}, &'t18 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'t19 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, fn(&'t20 str) -> pgwire::message::BackendMessage {pgwire::protocol::handle_query::{{closure}}#0::command_complete::<&'t20 str>}, &'t21 str, pgwire::message::BackendMessage, futures_util::sink::send::Send<'t22, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, futures_util::sink::send::Send<'t23, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, (), fn(std::result::Result<(), std::io::Error>) -> std::result::Result<<std::result::Result<(), std::io::Error> as std::ops::Try>::Ok, <std::result::Result<(), std::io::Error> as std::ops::Try>::Error> {<std::result::Result<(), std::io::Error> as std::ops::Try>::into_result}, &'t24 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'t25 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, fn(&'t26 str) -> pgwire::message::BackendMessage {pgwire::protocol::handle_query::{{closure}}#0::command_complete::<&'t26 str>}, &'t27 str, pgwire::message::BackendMessage, futures_util::sink::send::Send<'t28, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, futures_util::sink::send::Send<'t29, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, (), fn(std::result::Result<(), std::io::Error>) -> std::result::Result<<std::result::Result<(), std::io::Error> as std::ops::Try>::Ok, <std::result::Result<(), std::io::Error> as std::ops::Try>::Error> {<std::result::Result<(), std::io::Error> as std::ops::Try>::into_result}, &'t30 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'t31 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, fn(&'t32 str) -> pgwire::message::BackendMessage {pgwire::protocol::handle_query::{{closure}}#0::command_complete::<&'t32 str>}, &'t33 str, pgwire::message::BackendMessage, futures_util::sink::send::Send<'t34, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, futures_util::sink::send::Send<'t35, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, (), usize, fn(std::result::Result<(), std::io::Error>) -> std::result::Result<<std::result::Result<(), std::io::Error> as std::ops::Try>::Ok, <std::result::Result<(), std::io::Error> as std::ops::Try>::Error> {<std::result::Result<(), std::io::Error> as std::ops::Try>::into_result}, &'t36 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'t37 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, fn(std::string::String) -> pgwire::message::BackendMessage {pgwire::protocol::handle_query::{{closure}}#0::command_complete::<std::string::String>}, for<'t62> fn(std::fmt::Arguments<'t62>) -> std::string::String {std::fmt::format}, fn(&'t38 [&'t38 str], &'t38 [std::fmt::ArgumentV1<'t38>]) -> std::fmt::Arguments<'t38> {std::fmt::Arguments::<'t38>::new_v1}, &'t39 str, &'t40 str, [&'t41 str; 1], &'t42 [&'t43 str], &'t44 [&'t45 str; 1], usize, &'t46 usize, (&'t47 usize,), [std::fmt::ArgumentV1<'t48>; 1], &'t49 [std::fmt::ArgumentV1<'t50>], &'t51 [std::fmt::ArgumentV1<'t52>; 1], std::fmt::Arguments<'t53>, std::string::String, pgwire::message::BackendMessage, futures_util::sink::send::Send<'t54, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, futures_util::sink::send::Send<'t55, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, (), failure::error::Error, sql::session::session::Session, for<'_> fn(&mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, sql::session::session::Session, pgwire::protocol::Flow, &'static str, std::string::String) -> impl core::future::future::Future {pgwire::protocol::send_error::<tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, std::string::String>}, &'t56 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'t57 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, sql::session::session::Session, pgwire::protocol::Flow, &'t58 str, &'t59 failure::error::Error, failure::error::Error, std::string::String, impl core::future::future::Future, impl core::future::future::Future, ()}]` | |
| = note: required because it appears within the type `std::future::GenFuture<[static generator@DefId(275:266 ~ pgwire[22ad]::protocol[0]::handle_query[0]::{{closure}}[0]) 0:&mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, 1:&mut pgwire::protocol::Context, 2:futures_channel::oneshot::Receiver<coord::command::Response<coord::command::ExecuteResponse>>, 3:pgwire::protocol::Flow for<'r, 's, 't0, 't1, 't2, 't3, 't4, 't5, 't6, 't7, 't8, 't9, 't10, 't11, 't12, 't13, 't14, 't15, 't16, 't17, 't18, 't19, 't20, 't21, 't22, 't23, 't24, 't25, 't26, 't27, 't28, 't29, 't30, 't31, 't32, 't33, 't34, 't35, 't36, 't37, 't38, 't39, 't40, 't41, 't42, 't43, 't44, 't45, 't46, 't47, 't48, 't49, 't50, 't51, 't52, 't53, 't54, 't55, 't56, 't57, 't58, 't59, 't60, 't61> {&'r mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'s mut pgwire::protocol::Context, futures_channel::oneshot::Receiver<coord::command::Response<coord::command::ExecuteResponse>>, pgwire::protocol::Flow, fn(std::result::Result<coord::command::Response<coord::command::ExecuteResponse>, futures_channel::oneshot::Canceled>) -> std::result::Result<<std::result::Result<coord::command::Response<coord::command::ExecuteResponse>, futures_channel::oneshot::Canceled> as std::ops::Try>::Ok, <std::result::Result<coord::command::Response<coord::command::ExecuteResponse>, futures_channel::oneshot::Canceled> as std::ops::Try>::Error> {<std::result::Result<coord::command::Response<coord::command::ExecuteResponse>, futures_channel::oneshot::Canceled> as std::ops::Try>::into_result}, futures_channel::oneshot::Receiver<coord::command::Response<coord::command::ExecuteResponse>>, futures_channel::oneshot::Receiver<coord::command::Response<coord::command::ExecuteResponse>>, (), std::result::Result<coord::command::Response<coord::command::ExecuteResponse>, futures_channel::oneshot::Canceled>, std::result::Result<coord::command::Response<coord::command::ExecuteResponse>, futures_channel::oneshot::Canceled>, coord::command::Response<coord::command::ExecuteResponse>, coord::command::ExecuteResponse, sql::session::session::Session, coord::command::ExecuteResponse, fn(std::result::Result<(), std::io::Error>) -> std::result::Result<<std::result::Result<(), std::io::Error> as std::ops::Try>::Ok, <std::result::Result<(), std::io::Error> as std::ops::Try>::Error> {<std::result::Result<(), std::io::Error> as std::ops::Try>::into_result}, &'t0 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'t1 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, fn(&'t2 str) -> pgwire::message::BackendMessage {pgwire::protocol::handle_query::{{closure}}#0::command_complete::<&'t2 str>}, &'t3 str, pgwire::message::BackendMessage, futures_util::sink::send::Send<'t4, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, futures_util::sink::send::Send<'t5, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, (), fn(std::result::Result<(), std::io::Error>) -> std::result::Result<<std::result::Result<(), std::io::Error> as std::ops::Try>::Ok, <std::result::Result<(), std::io::Error> as std::ops::Try>::Error> {<std::result::Result<(), std::io::Error> as std::ops::Try>::into_result}, &'t6 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'t7 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, fn(&'t8 str) -> pgwire::message::BackendMessage {pgwire::protocol::handle_query::{{closure}}#0::command_complete::<&'t8 str>}, &'t9 str, pgwire::message::BackendMessage, futures_util::sink::send::Send<'t10, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, futures_util::sink::send::Send<'t11, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, (), fn(std::result::Result<(), std::io::Error>) -> std::result::Result<<std::result::Result<(), std::io::Error> as std::ops::Try>::Ok, <std::result::Result<(), std::io::Error> as std::ops::Try>::Error> {<std::result::Result<(), std::io::Error> as std::ops::Try>::into_result}, &'t12 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'t13 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, fn(&'t14 str) -> pgwire::message::BackendMessage {pgwire::protocol::handle_query::{{closure}}#0::command_complete::<&'t14 str>}, &'t15 str, pgwire::message::BackendMessage, futures_util::sink::send::Send<'t16, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, futures_util::sink::send::Send<'t17, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, (), fn(std::result::Result<(), std::io::Error>) -> std::result::Result<<std::result::Result<(), std::io::Error> as std::ops::Try>::Ok, <std::result::Result<(), std::io::Error> as std::ops::Try>::Error> {<std::result::Result<(), std::io::Error> as std::ops::Try>::into_result}, &'t18 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'t19 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, fn(&'t20 str) -> pgwire::message::BackendMessage {pgwire::protocol::handle_query::{{closure}}#0::command_complete::<&'t20 str>}, &'t21 str, pgwire::message::BackendMessage, futures_util::sink::send::Send<'t22, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, futures_util::sink::send::Send<'t23, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, (), fn(std::result::Result<(), std::io::Error>) -> std::result::Result<<std::result::Result<(), std::io::Error> as std::ops::Try>::Ok, <std::result::Result<(), std::io::Error> as std::ops::Try>::Error> {<std::result::Result<(), std::io::Error> as std::ops::Try>::into_result}, &'t24 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'t25 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, fn(&'t26 str) -> pgwire::message::BackendMessage {pgwire::protocol::handle_query::{{closure}}#0::command_complete::<&'t26 str>}, &'t27 str, pgwire::message::BackendMessage, futures_util::sink::send::Send<'t28, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, futures_util::sink::send::Send<'t29, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, (), fn(std::result::Result<(), std::io::Error>) -> std::result::Result<<std::result::Result<(), std::io::Error> as std::ops::Try>::Ok, <std::result::Result<(), std::io::Error> as std::ops::Try>::Error> {<std::result::Result<(), std::io::Error> as std::ops::Try>::into_result}, &'t30 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'t31 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, fn(&'t32 str) -> pgwire::message::BackendMessage {pgwire::protocol::handle_query::{{closure}}#0::command_complete::<&'t32 str>}, &'t33 str, pgwire::message::BackendMessage, futures_util::sink::send::Send<'t34, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, futures_util::sink::send::Send<'t35, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, (), usize, fn(std::result::Result<(), std::io::Error>) -> std::result::Result<<std::result::Result<(), std::io::Error> as std::ops::Try>::Ok, <std::result::Result<(), std::io::Error> as std::ops::Try>::Error> {<std::result::Result<(), std::io::Error> as std::ops::Try>::into_result}, &'t36 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'t37 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, fn(std::string::String) -> pgwire::message::BackendMessage {pgwire::protocol::handle_query::{{closure}}#0::command_complete::<std::string::String>}, for<'t62> fn(std::fmt::Arguments<'t62>) -> std::string::String {std::fmt::format}, fn(&'t38 [&'t38 str], &'t38 [std::fmt::ArgumentV1<'t38>]) -> std::fmt::Arguments<'t38> {std::fmt::Arguments::<'t38>::new_v1}, &'t39 str, &'t40 str, [&'t41 str; 1], &'t42 [&'t43 str], &'t44 [&'t45 str; 1], usize, &'t46 usize, (&'t47 usize,), [std::fmt::ArgumentV1<'t48>; 1], &'t49 [std::fmt::ArgumentV1<'t50>], &'t51 [std::fmt::ArgumentV1<'t52>; 1], std::fmt::Arguments<'t53>, std::string::String, pgwire::message::BackendMessage, futures_util::sink::send::Send<'t54, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, futures_util::sink::send::Send<'t55, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, (), failure::error::Error, sql::session::session::Session, for<'_> fn(&mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, sql::session::session::Session, pgwire::protocol::Flow, &'static str, std::string::String) -> impl core::future::future::Future {pgwire::protocol::send_error::<tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, std::string::String>}, &'t56 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'t57 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, sql::session::session::Session, pgwire::protocol::Flow, &'t58 str, &'t59 failure::error::Error, failure::error::Error, std::string::String, impl core::future::future::Future, impl core::future::future::Future, ()}]>` | |
| = note: required because it appears within the type `impl core::future::future::Future` | |
| = note: required because it appears within the type `impl core::future::future::Future` | |
| = note: required because it appears within the type `for<'r, 's, 't0, 't1, 't2, 't3, 't4, 't5, 't6, 't7, 't8, 't9, 't10, 't11, 't12, 't13, 't14, 't15, 't16, 't17, 't18, 't19> {&'r mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'s mut pgwire::protocol::Context, futures_channel::oneshot::Receiver<coord::command::Response<()>>, pgwire::protocol::Flow, fn(std::result::Result<coord::command::Response<()>, futures_channel::oneshot::Canceled>) -> std::result::Result<<std::result::Result<coord::command::Response<()>, futures_channel::oneshot::Canceled> as std::ops::Try>::Ok, <std::result::Result<coord::command::Response<()>, futures_channel::oneshot::Canceled> as std::ops::Try>::Error> {<std::result::Result<coord::command::Response<()>, futures_channel::oneshot::Canceled> as std::ops::Try>::into_result}, futures_channel::oneshot::Receiver<coord::command::Response<()>>, futures_channel::oneshot::Receiver<coord::command::Response<()>>, (), std::result::Result<coord::command::Response<()>, futures_channel::oneshot::Canceled>, std::result::Result<coord::command::Response<()>, futures_channel::oneshot::Canceled>, coord::command::Response<()>, sql::session::session::Session, pgwire::protocol::Flow, std::string::String, &'t0 sql::session::statement::PreparedStatement, std::option::Option<repr::relation::RelationDesc>, std::string::String, std::vec::Vec<(repr::scalar::Datum<'t1>, repr::scalar::ScalarType)>, std::vec::Vec<bool>, futures_channel::oneshot::Sender<coord::command::Response<coord::command::ExecuteResponse>>, futures_channel::oneshot::Receiver<coord::command::Response<coord::command::ExecuteResponse>>, pgwire::protocol::Context, &'t2 mut pgwire::protocol::Context, &'t3 mut futures_channel::mpsc::UnboundedSender<coord::command::Command>, futures_channel::mpsc::UnboundedSender<coord::command::Command>, &'t4 std::string::String, std::string::String, std::string::String, sql::session::session::Session, pgwire::protocol::Context, &'t5 mut pgwire::protocol::Context, u32, futures_channel::oneshot::Sender<coord::command::Response<coord::command::ExecuteResponse>>, coord::command::Command, futures_util::sink::send::Send<'t6, futures_channel::mpsc::UnboundedSender<coord::command::Command>, coord::command::Command>, futures_util::sink::send::Send<'t7, futures_channel::mpsc::UnboundedSender<coord::command::Command>, coord::command::Command>, (), for<'_, '_> fn(&mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &mut pgwire::protocol::Context, futures_channel::oneshot::Receiver<coord::command::Response<coord::command::ExecuteResponse>>, pgwire::protocol::Flow) -> impl core::future::future::Future {pgwire::protocol::handle_query::<tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>>}, &'t8 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'t9 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'t10 mut pgwire::protocol::Context, &'t11 mut pgwire::protocol::Context, futures_channel::oneshot::Receiver<coord::command::Response<coord::command::ExecuteResponse>>, pgwire::protocol::Flow, impl core::future::future::Future, impl core::future::future::Future, (), fn(std::result::Result<(), std::io::Error>) -> std::result::Result<<std::result::Result<(), std::io::Error> as std::ops::Try>::Ok, <std::result::Result<(), std::io::Error> as std::ops::Try>::Error> {<std::result::Result<(), std::io::Error> as std::ops::Try>::into_result}, &'t16 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'t17 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage, futures_util::sink::send::Send<'t18, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, futures_util::sink::send::Send<'t19, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, ()}` | |
| = note: required because it appears within the type `[static generator@DefId(275:262 ~ pgwire[22ad]::protocol[0]::handle_parse[0]::{{closure}}[0]) 0:&mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, 1:&mut pgwire::protocol::Context, 2:futures_channel::oneshot::Receiver<coord::command::Response<()>>, 3:pgwire::protocol::Flow for<'r, 's, 't0, 't1, 't2, 't3, 't4, 't5, 't6, 't7, 't8, 't9, 't10, 't11, 't12, 't13, 't14, 't15, 't16, 't17, 't18, 't19> {&'r mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'s mut pgwire::protocol::Context, futures_channel::oneshot::Receiver<coord::command::Response<()>>, pgwire::protocol::Flow, fn(std::result::Result<coord::command::Response<()>, futures_channel::oneshot::Canceled>) -> std::result::Result<<std::result::Result<coord::command::Response<()>, futures_channel::oneshot::Canceled> as std::ops::Try>::Ok, <std::result::Result<coord::command::Response<()>, futures_channel::oneshot::Canceled> as std::ops::Try>::Error> {<std::result::Result<coord::command::Response<()>, futures_channel::oneshot::Canceled> as std::ops::Try>::into_result}, futures_channel::oneshot::Receiver<coord::command::Response<()>>, futures_channel::oneshot::Receiver<coord::command::Response<()>>, (), std::result::Result<coord::command::Response<()>, futures_channel::oneshot::Canceled>, std::result::Result<coord::command::Response<()>, futures_channel::oneshot::Canceled>, coord::command::Response<()>, sql::session::session::Session, pgwire::protocol::Flow, std::string::String, &'t0 sql::session::statement::PreparedStatement, std::option::Option<repr::relation::RelationDesc>, std::string::String, std::vec::Vec<(repr::scalar::Datum<'t1>, repr::scalar::ScalarType)>, std::vec::Vec<bool>, futures_channel::oneshot::Sender<coord::command::Response<coord::command::ExecuteResponse>>, futures_channel::oneshot::Receiver<coord::command::Response<coord::command::ExecuteResponse>>, pgwire::protocol::Context, &'t2 mut pgwire::protocol::Context, &'t3 mut futures_channel::mpsc::UnboundedSender<coord::command::Command>, futures_channel::mpsc::UnboundedSender<coord::command::Command>, &'t4 std::string::String, std::string::String, std::string::String, sql::session::session::Session, pgwire::protocol::Context, &'t5 mut pgwire::protocol::Context, u32, futures_channel::oneshot::Sender<coord::command::Response<coord::command::ExecuteResponse>>, coord::command::Command, futures_util::sink::send::Send<'t6, futures_channel::mpsc::UnboundedSender<coord::command::Command>, coord::command::Command>, futures_util::sink::send::Send<'t7, futures_channel::mpsc::UnboundedSender<coord::command::Command>, coord::command::Command>, (), for<'_, '_> fn(&mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &mut pgwire::protocol::Context, futures_channel::oneshot::Receiver<coord::command::Response<coord::command::ExecuteResponse>>, pgwire::protocol::Flow) -> impl core::future::future::Future {pgwire::protocol::handle_query::<tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>>}, &'t8 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'t9 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'t10 mut pgwire::protocol::Context, &'t11 mut pgwire::protocol::Context, futures_channel::oneshot::Receiver<coord::command::Response<coord::command::ExecuteResponse>>, pgwire::protocol::Flow, impl core::future::future::Future, impl core::future::future::Future, (), fn(std::result::Result<(), std::io::Error>) -> std::result::Result<<std::result::Result<(), std::io::Error> as std::ops::Try>::Ok, <std::result::Result<(), std::io::Error> as std::ops::Try>::Error> {<std::result::Result<(), std::io::Error> as std::ops::Try>::into_result}, &'t16 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'t17 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage, futures_util::sink::send::Send<'t18, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, futures_util::sink::send::Send<'t19, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, ()}]` | |
| = note: required because it appears within the type `std::future::GenFuture<[static generator@DefId(275:262 ~ pgwire[22ad]::protocol[0]::handle_parse[0]::{{closure}}[0]) 0:&mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, 1:&mut pgwire::protocol::Context, 2:futures_channel::oneshot::Receiver<coord::command::Response<()>>, 3:pgwire::protocol::Flow for<'r, 's, 't0, 't1, 't2, 't3, 't4, 't5, 't6, 't7, 't8, 't9, 't10, 't11, 't12, 't13, 't14, 't15, 't16, 't17, 't18, 't19> {&'r mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'s mut pgwire::protocol::Context, futures_channel::oneshot::Receiver<coord::command::Response<()>>, pgwire::protocol::Flow, fn(std::result::Result<coord::command::Response<()>, futures_channel::oneshot::Canceled>) -> std::result::Result<<std::result::Result<coord::command::Response<()>, futures_channel::oneshot::Canceled> as std::ops::Try>::Ok, <std::result::Result<coord::command::Response<()>, futures_channel::oneshot::Canceled> as std::ops::Try>::Error> {<std::result::Result<coord::command::Response<()>, futures_channel::oneshot::Canceled> as std::ops::Try>::into_result}, futures_channel::oneshot::Receiver<coord::command::Response<()>>, futures_channel::oneshot::Receiver<coord::command::Response<()>>, (), std::result::Result<coord::command::Response<()>, futures_channel::oneshot::Canceled>, std::result::Result<coord::command::Response<()>, futures_channel::oneshot::Canceled>, coord::command::Response<()>, sql::session::session::Session, pgwire::protocol::Flow, std::string::String, &'t0 sql::session::statement::PreparedStatement, std::option::Option<repr::relation::RelationDesc>, std::string::String, std::vec::Vec<(repr::scalar::Datum<'t1>, repr::scalar::ScalarType)>, std::vec::Vec<bool>, futures_channel::oneshot::Sender<coord::command::Response<coord::command::ExecuteResponse>>, futures_channel::oneshot::Receiver<coord::command::Response<coord::command::ExecuteResponse>>, pgwire::protocol::Context, &'t2 mut pgwire::protocol::Context, &'t3 mut futures_channel::mpsc::UnboundedSender<coord::command::Command>, futures_channel::mpsc::UnboundedSender<coord::command::Command>, &'t4 std::string::String, std::string::String, std::string::String, sql::session::session::Session, pgwire::protocol::Context, &'t5 mut pgwire::protocol::Context, u32, futures_channel::oneshot::Sender<coord::command::Response<coord::command::ExecuteResponse>>, coord::command::Command, futures_util::sink::send::Send<'t6, futures_channel::mpsc::UnboundedSender<coord::command::Command>, coord::command::Command>, futures_util::sink::send::Send<'t7, futures_channel::mpsc::UnboundedSender<coord::command::Command>, coord::command::Command>, (), for<'_, '_> fn(&mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &mut pgwire::protocol::Context, futures_channel::oneshot::Receiver<coord::command::Response<coord::command::ExecuteResponse>>, pgwire::protocol::Flow) -> impl core::future::future::Future {pgwire::protocol::handle_query::<tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>>}, &'t8 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'t9 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'t10 mut pgwire::protocol::Context, &'t11 mut pgwire::protocol::Context, futures_channel::oneshot::Receiver<coord::command::Response<coord::command::ExecuteResponse>>, pgwire::protocol::Flow, impl core::future::future::Future, impl core::future::future::Future, (), fn(std::result::Result<(), std::io::Error>) -> std::result::Result<<std::result::Result<(), std::io::Error> as std::ops::Try>::Ok, <std::result::Result<(), std::io::Error> as std::ops::Try>::Error> {<std::result::Result<(), std::io::Error> as std::ops::Try>::into_result}, &'t16 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'t17 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage, futures_util::sink::send::Send<'t18, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, futures_util::sink::send::Send<'t19, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, ()}]>` | |
| = note: required because it appears within the type `impl core::future::future::Future` | |
| = note: required because it appears within the type `impl core::future::future::Future` | |
| = note: required because it appears within the type `for<'r, 's, 't0, 't1, 't2, 't3, 't4, 't5, 't6, 't7, 't8, 't9, 't10, 't11, 't12, 't13, 't14, 't15, 't16, 't17, 't18, 't19, 't20, 't21, 't22, 't23, 't24, 't25, 't26, 't27, 't28, 't29, 't30, 't31, 't32, 't33, 't34, 't35, 't36, 't37, 't38, 't39, 't40, 't41, 't42, 't43, 't44> {&'r mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, sql::session::session::Session, sql::session::session::Session, &'s mut pgwire::protocol::Context, fn(std::result::Result<pgwire::message::FrontendMessage, std::io::Error>) -> std::result::Result<<std::result::Result<pgwire::message::FrontendMessage, std::io::Error> as std::ops::Try>::Ok, <std::result::Result<pgwire::message::FrontendMessage, std::io::Error> as std::ops::Try>::Error> {<std::result::Result<pgwire::message::FrontendMessage, std::io::Error> as std::ops::Try>::into_result}, &'t0 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'t1 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, ore::future::TryRecv<'t2, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>>, ore::future::TryRecv<'t3, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>>, (), std::result::Result<pgwire::message::FrontendMessage, std::io::Error>, std::result::Result<pgwire::message::FrontendMessage, std::io::Error>, pgwire::message::FrontendMessage, std::string::String, futures_channel::oneshot::Sender<coord::command::Response<()>>, futures_channel::oneshot::Receiver<coord::command::Response<()>>, fn(std::result::Result<(), futures_channel::mpsc::SendError>) -> std::result::Result<<std::result::Result<(), futures_channel::mpsc::SendError> as std::ops::Try>::Ok, <std::result::Result<(), futures_channel::mpsc::SendError> as std::ops::Try>::Error> {<std::result::Result<(), futures_channel::mpsc::SendError> as std::ops::Try>::into_result}, pgwire::protocol::Context, &'t4 mut pgwire::protocol::Context, &'t5 mut futures_channel::mpsc::UnboundedSender<coord::command::Command>, futures_channel::mpsc::UnboundedSender<coord::command::Command>, &'t6 str, &'t7 str, std::string::String, std::string::String, sql::session::session::Session, futures_channel::oneshot::Sender<coord::command::Response<()>>, coord::command::Command, futures_util::sink::send::Send<'t8, futures_channel::mpsc::UnboundedSender<coord::command::Command>, coord::command::Command>, futures_util::sink::send::Send<'t9, futures_channel::mpsc::UnboundedSender<coord::command::Command>, coord::command::Command>, (), for<'_, '_> fn(&mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &mut pgwire::protocol::Context, futures_channel::oneshot::Receiver<coord::command::Response<()>>, pgwire::protocol::Flow) -> impl core::future::future::Future {pgwire::protocol::handle_parse::<tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>>}, &'t10 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'t11 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'t12 mut pgwire::protocol::Context, &'t13 mut pgwire::protocol::Context, futures_channel::oneshot::Receiver<coord::command::Response<()>>, pgwire::protocol::Flow, impl core::future::future::Future, impl core::future::future::Future, (), std::string::String, std::string::String, futures_channel::oneshot::Sender<coord::command::Response<()>>, futures_channel::oneshot::Receiver<coord::command::Response<()>>, fn(std::result::Result<(), futures_channel::mpsc::SendError>) -> std::result::Result<<std::result::Result<(), futures_channel::mpsc::SendError> as std::ops::Try>::Ok, <std::result::Result<(), futures_channel::mpsc::SendError> as std::ops::Try>::Error> {<std::result::Result<(), futures_channel::mpsc::SendError> as std::ops::Try>::into_result}, pgwire::protocol::Context, &'t18 mut pgwire::protocol::Context, &'t19 mut futures_channel::mpsc::UnboundedSender<coord::command::Command>, futures_channel::mpsc::UnboundedSender<coord::command::Command>, std::string::String, std::string::String, sql::session::session::Session, futures_channel::oneshot::Sender<coord::command::Response<()>>, coord::command::Command, futures_util::sink::send::Send<'t20, futures_channel::mpsc::UnboundedSender<coord::command::Command>, coord::command::Command>, futures_util::sink::send::Send<'t21, futures_channel::mpsc::UnboundedSender<coord::command::Command>, coord::command::Command>, (), for<'_, '_> fn(&mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &mut pgwire::protocol::Context, futures_channel::oneshot::Receiver<coord::command::Response<()>>, pgwire::protocol::Flow) -> impl core::future::future::Future {pgwire::protocol::handle_parse::<tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>>}, &'t22 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'t23 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'t24 mut pgwire::protocol::Context, &'t25 mut pgwire::protocol::Context, futures_channel::oneshot::Receiver<coord::command::Response<()>>, pgwire::protocol::Flow, impl core::future::future::Future, impl core::future::future::Future, (), std::string::String, fn(std::result::Result<(), std::io::Error>) -> std::result::Result<<std::result::Result<(), std::io::Error> as std::ops::Try>::Ok, <std::result::Result<(), std::io::Error> as std::ops::Try>::Error> {<std::result::Result<(), std::io::Error> as std::ops::Try>::into_result}, &'t30 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'t31 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage, futures_util::sink::send::Send<'t32, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, futures_util::sink::send::Send<'t33, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, (), std::string::String, fn(std::result::Result<(), std::io::Error>) -> std::result::Result<<std::result::Result<(), std::io::Error> as std::ops::Try>::Ok, <std::result::Result<(), std::io::Error> as std::ops::Try>::Error> {<std::result::Result<(), std::io::Error> as std::ops::Try>::into_result}, &'t34 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'t35 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage, futures_util::sink::send::Send<'t36, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, futures_util::sink::send::Send<'t37, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, (), fn(std::result::Result<(), std::io::Error>) -> std::result::Result<<std::result::Result<(), std::io::Error> as std::ops::Try>::Ok, <std::result::Result<(), std::io::Error> as std::ops::Try>::Error> {<std::result::Result<(), std::io::Error> as std::ops::Try>::into_result}, &'t38 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'t39 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, fn(pgwire::message::TransactionStatus) -> pgwire::message::BackendMessage {pgwire::message::BackendMessage::ReadyForQuery}, &'t40 sql::session::session::Session, sql::session::session::Session, &'t41 sql::session::transaction::TransactionStatus, &'t42 sql::session::transaction::TransactionStatus, pgwire::message::TransactionStatus, pgwire::message::BackendMessage, futures_util::sink::send::Send<'t43, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, futures_util::sink::send::Send<'t44, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, ()}` | |
| = note: required because it appears within the type `[static generator@DefId(275:258 ~ pgwire[22ad]::protocol[0]::handle_ready[0]::{{closure}}[0]) 0:&mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, 1:sql::session::session::Session, 2:&mut pgwire::protocol::Context for<'r, 's, 't0, 't1, 't2, 't3, 't4, 't5, 't6, 't7, 't8, 't9, 't10, 't11, 't12, 't13, 't14, 't15, 't16, 't17, 't18, 't19, 't20, 't21, 't22, 't23, 't24, 't25, 't26, 't27, 't28, 't29, 't30, 't31, 't32, 't33, 't34, 't35, 't36, 't37, 't38, 't39, 't40, 't41, 't42, 't43, 't44> {&'r mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, sql::session::session::Session, sql::session::session::Session, &'s mut pgwire::protocol::Context, fn(std::result::Result<pgwire::message::FrontendMessage, std::io::Error>) -> std::result::Result<<std::result::Result<pgwire::message::FrontendMessage, std::io::Error> as std::ops::Try>::Ok, <std::result::Result<pgwire::message::FrontendMessage, std::io::Error> as std::ops::Try>::Error> {<std::result::Result<pgwire::message::FrontendMessage, std::io::Error> as std::ops::Try>::into_result}, &'t0 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'t1 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, ore::future::TryRecv<'t2, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>>, ore::future::TryRecv<'t3, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>>, (), std::result::Result<pgwire::message::FrontendMessage, std::io::Error>, std::result::Result<pgwire::message::FrontendMessage, std::io::Error>, pgwire::message::FrontendMessage, std::string::String, futures_channel::oneshot::Sender<coord::command::Response<()>>, futures_channel::oneshot::Receiver<coord::command::Response<()>>, fn(std::result::Result<(), futures_channel::mpsc::SendError>) -> std::result::Result<<std::result::Result<(), futures_channel::mpsc::SendError> as std::ops::Try>::Ok, <std::result::Result<(), futures_channel::mpsc::SendError> as std::ops::Try>::Error> {<std::result::Result<(), futures_channel::mpsc::SendError> as std::ops::Try>::into_result}, pgwire::protocol::Context, &'t4 mut pgwire::protocol::Context, &'t5 mut futures_channel::mpsc::UnboundedSender<coord::command::Command>, futures_channel::mpsc::UnboundedSender<coord::command::Command>, &'t6 str, &'t7 str, std::string::String, std::string::String, sql::session::session::Session, futures_channel::oneshot::Sender<coord::command::Response<()>>, coord::command::Command, futures_util::sink::send::Send<'t8, futures_channel::mpsc::UnboundedSender<coord::command::Command>, coord::command::Command>, futures_util::sink::send::Send<'t9, futures_channel::mpsc::UnboundedSender<coord::command::Command>, coord::command::Command>, (), for<'_, '_> fn(&mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &mut pgwire::protocol::Context, futures_channel::oneshot::Receiver<coord::command::Response<()>>, pgwire::protocol::Flow) -> impl core::future::future::Future {pgwire::protocol::handle_parse::<tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>>}, &'t10 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'t11 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'t12 mut pgwire::protocol::Context, &'t13 mut pgwire::protocol::Context, futures_channel::oneshot::Receiver<coord::command::Response<()>>, pgwire::protocol::Flow, impl core::future::future::Future, impl core::future::future::Future, (), std::string::String, std::string::String, futures_channel::oneshot::Sender<coord::command::Response<()>>, futures_channel::oneshot::Receiver<coord::command::Response<()>>, fn(std::result::Result<(), futures_channel::mpsc::SendError>) -> std::result::Result<<std::result::Result<(), futures_channel::mpsc::SendError> as std::ops::Try>::Ok, <std::result::Result<(), futures_channel::mpsc::SendError> as std::ops::Try>::Error> {<std::result::Result<(), futures_channel::mpsc::SendError> as std::ops::Try>::into_result}, pgwire::protocol::Context, &'t18 mut pgwire::protocol::Context, &'t19 mut futures_channel::mpsc::UnboundedSender<coord::command::Command>, futures_channel::mpsc::UnboundedSender<coord::command::Command>, std::string::String, std::string::String, sql::session::session::Session, futures_channel::oneshot::Sender<coord::command::Response<()>>, coord::command::Command, futures_util::sink::send::Send<'t20, futures_channel::mpsc::UnboundedSender<coord::command::Command>, coord::command::Command>, futures_util::sink::send::Send<'t21, futures_channel::mpsc::UnboundedSender<coord::command::Command>, coord::command::Command>, (), for<'_, '_> fn(&mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &mut pgwire::protocol::Context, futures_channel::oneshot::Receiver<coord::command::Response<()>>, pgwire::protocol::Flow) -> impl core::future::future::Future {pgwire::protocol::handle_parse::<tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>>}, &'t22 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'t23 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'t24 mut pgwire::protocol::Context, &'t25 mut pgwire::protocol::Context, futures_channel::oneshot::Receiver<coord::command::Response<()>>, pgwire::protocol::Flow, impl core::future::future::Future, impl core::future::future::Future, (), std::string::String, fn(std::result::Result<(), std::io::Error>) -> std::result::Result<<std::result::Result<(), std::io::Error> as std::ops::Try>::Ok, <std::result::Result<(), std::io::Error> as std::ops::Try>::Error> {<std::result::Result<(), std::io::Error> as std::ops::Try>::into_result}, &'t30 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'t31 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage, futures_util::sink::send::Send<'t32, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, futures_util::sink::send::Send<'t33, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, (), std::string::String, fn(std::result::Result<(), std::io::Error>) -> std::result::Result<<std::result::Result<(), std::io::Error> as std::ops::Try>::Ok, <std::result::Result<(), std::io::Error> as std::ops::Try>::Error> {<std::result::Result<(), std::io::Error> as std::ops::Try>::into_result}, &'t34 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'t35 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage, futures_util::sink::send::Send<'t36, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, futures_util::sink::send::Send<'t37, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, (), fn(std::result::Result<(), std::io::Error>) -> std::result::Result<<std::result::Result<(), std::io::Error> as std::ops::Try>::Ok, <std::result::Result<(), std::io::Error> as std::ops::Try>::Error> {<std::result::Result<(), std::io::Error> as std::ops::Try>::into_result}, &'t38 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'t39 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, fn(pgwire::message::TransactionStatus) -> pgwire::message::BackendMessage {pgwire::message::BackendMessage::ReadyForQuery}, &'t40 sql::session::session::Session, sql::session::session::Session, &'t41 sql::session::transaction::TransactionStatus, &'t42 sql::session::transaction::TransactionStatus, pgwire::message::TransactionStatus, pgwire::message::BackendMessage, futures_util::sink::send::Send<'t43, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, futures_util::sink::send::Send<'t44, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, ()}]` | |
| = note: required because it appears within the type `std::future::GenFuture<[static generator@DefId(275:258 ~ pgwire[22ad]::protocol[0]::handle_ready[0]::{{closure}}[0]) 0:&mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, 1:sql::session::session::Session, 2:&mut pgwire::protocol::Context for<'r, 's, 't0, 't1, 't2, 't3, 't4, 't5, 't6, 't7, 't8, 't9, 't10, 't11, 't12, 't13, 't14, 't15, 't16, 't17, 't18, 't19, 't20, 't21, 't22, 't23, 't24, 't25, 't26, 't27, 't28, 't29, 't30, 't31, 't32, 't33, 't34, 't35, 't36, 't37, 't38, 't39, 't40, 't41, 't42, 't43, 't44> {&'r mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, sql::session::session::Session, sql::session::session::Session, &'s mut pgwire::protocol::Context, fn(std::result::Result<pgwire::message::FrontendMessage, std::io::Error>) -> std::result::Result<<std::result::Result<pgwire::message::FrontendMessage, std::io::Error> as std::ops::Try>::Ok, <std::result::Result<pgwire::message::FrontendMessage, std::io::Error> as std::ops::Try>::Error> {<std::result::Result<pgwire::message::FrontendMessage, std::io::Error> as std::ops::Try>::into_result}, &'t0 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'t1 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, ore::future::TryRecv<'t2, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>>, ore::future::TryRecv<'t3, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>>, (), std::result::Result<pgwire::message::FrontendMessage, std::io::Error>, std::result::Result<pgwire::message::FrontendMessage, std::io::Error>, pgwire::message::FrontendMessage, std::string::String, futures_channel::oneshot::Sender<coord::command::Response<()>>, futures_channel::oneshot::Receiver<coord::command::Response<()>>, fn(std::result::Result<(), futures_channel::mpsc::SendError>) -> std::result::Result<<std::result::Result<(), futures_channel::mpsc::SendError> as std::ops::Try>::Ok, <std::result::Result<(), futures_channel::mpsc::SendError> as std::ops::Try>::Error> {<std::result::Result<(), futures_channel::mpsc::SendError> as std::ops::Try>::into_result}, pgwire::protocol::Context, &'t4 mut pgwire::protocol::Context, &'t5 mut futures_channel::mpsc::UnboundedSender<coord::command::Command>, futures_channel::mpsc::UnboundedSender<coord::command::Command>, &'t6 str, &'t7 str, std::string::String, std::string::String, sql::session::session::Session, futures_channel::oneshot::Sender<coord::command::Response<()>>, coord::command::Command, futures_util::sink::send::Send<'t8, futures_channel::mpsc::UnboundedSender<coord::command::Command>, coord::command::Command>, futures_util::sink::send::Send<'t9, futures_channel::mpsc::UnboundedSender<coord::command::Command>, coord::command::Command>, (), for<'_, '_> fn(&mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &mut pgwire::protocol::Context, futures_channel::oneshot::Receiver<coord::command::Response<()>>, pgwire::protocol::Flow) -> impl core::future::future::Future {pgwire::protocol::handle_parse::<tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>>}, &'t10 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'t11 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'t12 mut pgwire::protocol::Context, &'t13 mut pgwire::protocol::Context, futures_channel::oneshot::Receiver<coord::command::Response<()>>, pgwire::protocol::Flow, impl core::future::future::Future, impl core::future::future::Future, (), std::string::String, std::string::String, futures_channel::oneshot::Sender<coord::command::Response<()>>, futures_channel::oneshot::Receiver<coord::command::Response<()>>, fn(std::result::Result<(), futures_channel::mpsc::SendError>) -> std::result::Result<<std::result::Result<(), futures_channel::mpsc::SendError> as std::ops::Try>::Ok, <std::result::Result<(), futures_channel::mpsc::SendError> as std::ops::Try>::Error> {<std::result::Result<(), futures_channel::mpsc::SendError> as std::ops::Try>::into_result}, pgwire::protocol::Context, &'t18 mut pgwire::protocol::Context, &'t19 mut futures_channel::mpsc::UnboundedSender<coord::command::Command>, futures_channel::mpsc::UnboundedSender<coord::command::Command>, std::string::String, std::string::String, sql::session::session::Session, futures_channel::oneshot::Sender<coord::command::Response<()>>, coord::command::Command, futures_util::sink::send::Send<'t20, futures_channel::mpsc::UnboundedSender<coord::command::Command>, coord::command::Command>, futures_util::sink::send::Send<'t21, futures_channel::mpsc::UnboundedSender<coord::command::Command>, coord::command::Command>, (), for<'_, '_> fn(&mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &mut pgwire::protocol::Context, futures_channel::oneshot::Receiver<coord::command::Response<()>>, pgwire::protocol::Flow) -> impl core::future::future::Future {pgwire::protocol::handle_parse::<tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>>}, &'t22 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'t23 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'t24 mut pgwire::protocol::Context, &'t25 mut pgwire::protocol::Context, futures_channel::oneshot::Receiver<coord::command::Response<()>>, pgwire::protocol::Flow, impl core::future::future::Future, impl core::future::future::Future, (), std::string::String, fn(std::result::Result<(), std::io::Error>) -> std::result::Result<<std::result::Result<(), std::io::Error> as std::ops::Try>::Ok, <std::result::Result<(), std::io::Error> as std::ops::Try>::Error> {<std::result::Result<(), std::io::Error> as std::ops::Try>::into_result}, &'t30 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'t31 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage, futures_util::sink::send::Send<'t32, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, futures_util::sink::send::Send<'t33, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, (), std::string::String, fn(std::result::Result<(), std::io::Error>) -> std::result::Result<<std::result::Result<(), std::io::Error> as std::ops::Try>::Ok, <std::result::Result<(), std::io::Error> as std::ops::Try>::Error> {<std::result::Result<(), std::io::Error> as std::ops::Try>::into_result}, &'t34 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'t35 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage, futures_util::sink::send::Send<'t36, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, futures_util::sink::send::Send<'t37, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, (), fn(std::result::Result<(), std::io::Error>) -> std::result::Result<<std::result::Result<(), std::io::Error> as std::ops::Try>::Ok, <std::result::Result<(), std::io::Error> as std::ops::Try>::Error> {<std::result::Result<(), std::io::Error> as std::ops::Try>::into_result}, &'t38 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'t39 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, fn(pgwire::message::TransactionStatus) -> pgwire::message::BackendMessage {pgwire::message::BackendMessage::ReadyForQuery}, &'t40 sql::session::session::Session, sql::session::session::Session, &'t41 sql::session::transaction::TransactionStatus, &'t42 sql::session::transaction::TransactionStatus, pgwire::message::TransactionStatus, pgwire::message::BackendMessage, futures_util::sink::send::Send<'t43, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, futures_util::sink::send::Send<'t44, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, pgwire::message::BackendMessage>, ()}]>` | |
| = note: required because it appears within the type `impl core::future::future::Future` | |
| = note: required because it appears within the type `impl core::future::future::Future` | |
| = note: required because it appears within the type `for<'r, 's, 't0, 't1, 't2, 't3, 't4, 't5, 't6, 't7, 't8, 't9, 't10, 't11, 't12, 't13, 't14, 't15> {&'r mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, sql::session::session::Session, pgwire::protocol::Context, pgwire::protocol::Context, pgwire::protocol::State, &'s mut pgwire::protocol::State, pgwire::protocol::State, pgwire::protocol::State, sql::session::session::Session, fn(std::result::Result<pgwire::protocol::State, failure::error::Error>) -> std::result::Result<<std::result::Result<pgwire::protocol::State, failure::error::Error> as std::ops::Try>::Ok, <std::result::Result<pgwire::protocol::State, failure::error::Error> as std::ops::Try>::Error> {<std::result::Result<pgwire::protocol::State, failure::error::Error> as std::ops::Try>::into_result}, for<'_, '_> fn(&mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, sql::session::session::Session, &mut pgwire::protocol::Context) -> impl core::future::future::Future {pgwire::protocol::handle_startup::<tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>>}, &'t0 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'t1 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, sql::session::session::Session, pgwire::protocol::Context, &'t2 mut pgwire::protocol::Context, &'t3 mut pgwire::protocol::Context, impl core::future::future::Future, impl core::future::future::Future, (), sql::session::session::Session, fn(std::result::Result<pgwire::protocol::State, failure::error::Error>) -> std::result::Result<<std::result::Result<pgwire::protocol::State, failure::error::Error> as std::ops::Try>::Ok, <std::result::Result<pgwire::protocol::State, failure::error::Error> as std::ops::Try>::Error> {<std::result::Result<pgwire::protocol::State, failure::error::Error> as std::ops::Try>::into_result}, for<'_, '_> fn(&mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, sql::session::session::Session, &mut pgwire::protocol::Context) -> impl core::future::future::Future {pgwire::protocol::handle_ready::<tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>>}, &'t8 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'t9 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, sql::session::session::Session, pgwire::protocol::Context, &'t10 mut pgwire::protocol::Context, &'t11 mut pgwire::protocol::Context, impl core::future::future::Future, impl core::future::future::Future, ()}` | |
| = note: required because it appears within the type `[static generator@DefId(275:238 ~ pgwire[22ad]::protocol[0]::serve[0]::{{closure}}[0]) 0:&mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, 1:sql::session::session::Session, 2:pgwire::protocol::Context for<'r, 's, 't0, 't1, 't2, 't3, 't4, 't5, 't6, 't7, 't8, 't9, 't10, 't11, 't12, 't13, 't14, 't15> {&'r mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, sql::session::session::Session, pgwire::protocol::Context, pgwire::protocol::Context, pgwire::protocol::State, &'s mut pgwire::protocol::State, pgwire::protocol::State, pgwire::protocol::State, sql::session::session::Session, fn(std::result::Result<pgwire::protocol::State, failure::error::Error>) -> std::result::Result<<std::result::Result<pgwire::protocol::State, failure::error::Error> as std::ops::Try>::Ok, <std::result::Result<pgwire::protocol::State, failure::error::Error> as std::ops::Try>::Error> {<std::result::Result<pgwire::protocol::State, failure::error::Error> as std::ops::Try>::into_result}, for<'_, '_> fn(&mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, sql::session::session::Session, &mut pgwire::protocol::Context) -> impl core::future::future::Future {pgwire::protocol::handle_startup::<tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>>}, &'t0 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'t1 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, sql::session::session::Session, pgwire::protocol::Context, &'t2 mut pgwire::protocol::Context, &'t3 mut pgwire::protocol::Context, impl core::future::future::Future, impl core::future::future::Future, (), sql::session::session::Session, fn(std::result::Result<pgwire::protocol::State, failure::error::Error>) -> std::result::Result<<std::result::Result<pgwire::protocol::State, failure::error::Error> as std::ops::Try>::Ok, <std::result::Result<pgwire::protocol::State, failure::error::Error> as std::ops::Try>::Error> {<std::result::Result<pgwire::protocol::State, failure::error::Error> as std::ops::Try>::into_result}, for<'_, '_> fn(&mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, sql::session::session::Session, &mut pgwire::protocol::Context) -> impl core::future::future::Future {pgwire::protocol::handle_ready::<tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>>}, &'t8 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'t9 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, sql::session::session::Session, pgwire::protocol::Context, &'t10 mut pgwire::protocol::Context, &'t11 mut pgwire::protocol::Context, impl core::future::future::Future, impl core::future::future::Future, ()}]` | |
| = note: required because it appears within the type `std::future::GenFuture<[static generator@DefId(275:238 ~ pgwire[22ad]::protocol[0]::serve[0]::{{closure}}[0]) 0:&mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, 1:sql::session::session::Session, 2:pgwire::protocol::Context for<'r, 's, 't0, 't1, 't2, 't3, 't4, 't5, 't6, 't7, 't8, 't9, 't10, 't11, 't12, 't13, 't14, 't15> {&'r mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, sql::session::session::Session, pgwire::protocol::Context, pgwire::protocol::Context, pgwire::protocol::State, &'s mut pgwire::protocol::State, pgwire::protocol::State, pgwire::protocol::State, sql::session::session::Session, fn(std::result::Result<pgwire::protocol::State, failure::error::Error>) -> std::result::Result<<std::result::Result<pgwire::protocol::State, failure::error::Error> as std::ops::Try>::Ok, <std::result::Result<pgwire::protocol::State, failure::error::Error> as std::ops::Try>::Error> {<std::result::Result<pgwire::protocol::State, failure::error::Error> as std::ops::Try>::into_result}, for<'_, '_> fn(&mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, sql::session::session::Session, &mut pgwire::protocol::Context) -> impl core::future::future::Future {pgwire::protocol::handle_startup::<tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>>}, &'t0 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'t1 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, sql::session::session::Session, pgwire::protocol::Context, &'t2 mut pgwire::protocol::Context, &'t3 mut pgwire::protocol::Context, impl core::future::future::Future, impl core::future::future::Future, (), sql::session::session::Session, fn(std::result::Result<pgwire::protocol::State, failure::error::Error>) -> std::result::Result<<std::result::Result<pgwire::protocol::State, failure::error::Error> as std::ops::Try>::Ok, <std::result::Result<pgwire::protocol::State, failure::error::Error> as std::ops::Try>::Error> {<std::result::Result<pgwire::protocol::State, failure::error::Error> as std::ops::Try>::into_result}, for<'_, '_> fn(&mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, sql::session::session::Session, &mut pgwire::protocol::Context) -> impl core::future::future::Future {pgwire::protocol::handle_ready::<tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>>}, &'t8 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'t9 mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, sql::session::session::Session, pgwire::protocol::Context, &'t10 mut pgwire::protocol::Context, &'t11 mut pgwire::protocol::Context, impl core::future::future::Future, impl core::future::future::Future, ()}]>` | |
| = note: required because it appears within the type `impl core::future::future::Future` | |
| = note: required because it appears within the type `impl core::future::future::Future` | |
| = note: required because it appears within the type `for<'r, 's, 't0, 't1, 't2> {ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, futures_channel::mpsc::UnboundedSender<coord::command::Command>, bool, u32, for<'_> fn(&mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, sql::session::session::Session, pgwire::protocol::Context) -> impl core::future::future::Future {pgwire::protocol::serve::<tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>>}, fn(ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec) -> tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec> {tokio_util::codec::framed::Framed::<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>::new}, ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, fn() -> pgwire::codec::Codec {pgwire::codec::Codec::new}, pgwire::codec::Codec, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'r mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'s mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, fn() -> sql::session::session::Session {<sql::session::session::Session as std::default::Default>::default}, sql::session::session::Session, u32, &'t0 pgwire::secrets::SecretManager, pgwire::serve::{{closure}}#0::CONN_SECRETS, pgwire::secrets::SecretManager, futures_channel::mpsc::UnboundedSender<coord::command::Command>, bool, pgwire::protocol::Context, impl core::future::future::Future, impl core::future::future::Future, ()}` | |
| = note: required because it appears within the type `[static generator@DefId(275:316 ~ pgwire[22ad]::serve[0]::{{closure}}[0]) 0:ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, 1:futures_channel::mpsc::UnboundedSender<coord::command::Command>, 2:bool for<'r, 's, 't0, 't1, 't2> {ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, futures_channel::mpsc::UnboundedSender<coord::command::Command>, bool, u32, for<'_> fn(&mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, sql::session::session::Session, pgwire::protocol::Context) -> impl core::future::future::Future {pgwire::protocol::serve::<tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>>}, fn(ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec) -> tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec> {tokio_util::codec::framed::Framed::<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>::new}, ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, fn() -> pgwire::codec::Codec {pgwire::codec::Codec::new}, pgwire::codec::Codec, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'r mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'s mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, fn() -> sql::session::session::Session {<sql::session::session::Session as std::default::Default>::default}, sql::session::session::Session, u32, &'t0 pgwire::secrets::SecretManager, pgwire::serve::{{closure}}#0::CONN_SECRETS, pgwire::secrets::SecretManager, futures_channel::mpsc::UnboundedSender<coord::command::Command>, bool, pgwire::protocol::Context, impl core::future::future::Future, impl core::future::future::Future, ()}]` | |
| = note: required because it appears within the type `std::future::GenFuture<[static generator@DefId(275:316 ~ pgwire[22ad]::serve[0]::{{closure}}[0]) 0:ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, 1:futures_channel::mpsc::UnboundedSender<coord::command::Command>, 2:bool for<'r, 's, 't0, 't1, 't2> {ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, futures_channel::mpsc::UnboundedSender<coord::command::Command>, bool, u32, for<'_> fn(&mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, sql::session::session::Session, pgwire::protocol::Context) -> impl core::future::future::Future {pgwire::protocol::serve::<tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>>}, fn(ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec) -> tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec> {tokio_util::codec::framed::Framed::<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>::new}, ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, fn() -> pgwire::codec::Codec {pgwire::codec::Codec::new}, pgwire::codec::Codec, tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'r mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, &'s mut tokio_util::codec::framed::Framed<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, pgwire::codec::Codec>, fn() -> sql::session::session::Session {<sql::session::session::Session as std::default::Default>::default}, sql::session::session::Session, u32, &'t0 pgwire::secrets::SecretManager, pgwire::serve::{{closure}}#0::CONN_SECRETS, pgwire::secrets::SecretManager, futures_channel::mpsc::UnboundedSender<coord::command::Command>, bool, pgwire::protocol::Context, impl core::future::future::Future, impl core::future::future::Future, ()}]>` | |
| = note: required because it appears within the type `impl core::future::future::Future` | |
| = note: required because it appears within the type `impl core::future::future::Future` | |
| = note: required because it appears within the type `for<'r, 's, 't0, 't1, 't2, 't3, 't4, 't5, 't6, 't7, 't8, 't9, 't10, 't11, 't12, 't13> {tokio::net::tcp::stream::TcpStream, comm::switchboard::Switchboard<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>>, futures_channel::mpsc::UnboundedSender<coord::command::Command>, bool, ore::netio::stream::SniffingStream<tokio::net::tcp::stream::TcpStream>, [u8; 8], for<'a> fn(&'a mut ore::netio::stream::SniffingStream<tokio::net::tcp::stream::TcpStream>, &'a mut [u8]) -> ore::netio::read_exact::ReadExactOrEof<'a, ore::netio::stream::SniffingStream<tokio::net::tcp::stream::TcpStream>> {ore::netio::read_exact::read_exact_or_eof::<ore::netio::stream::SniffingStream<tokio::net::tcp::stream::TcpStream>>}, ore::netio::stream::SniffingStream<tokio::net::tcp::stream::TcpStream>, &'r mut ore::netio::stream::SniffingStream<tokio::net::tcp::stream::TcpStream>, &'s mut ore::netio::stream::SniffingStream<tokio::net::tcp::stream::TcpStream>, [u8; 8], &'t0 mut [u8], &'t1 mut [u8; 8], ore::netio::read_exact::ReadExactOrEof<'t2, ore::netio::stream::SniffingStream<tokio::net::tcp::stream::TcpStream>>, ore::netio::read_exact::ReadExactOrEof<'t3, ore::netio::stream::SniffingStream<tokio::net::tcp::stream::TcpStream>>, (), usize, &'t4 [u8], [u8; 8], [u8], &'t5 [u8], bool, bool, fn(ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, futures_channel::mpsc::UnboundedSender<coord::command::Command>, bool) -> impl core::future::future::Future {pgwire::serve::<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>>}, ore::netio::stream::SniffingStream<tokio::net::tcp::stream::TcpStream>, ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, futures_channel::mpsc::UnboundedSender<coord::command::Command>, bool, impl core::future::future::Future, impl core::future::future::Future, (), bool, bool, fn(ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, bool) -> impl core::future::future::Future {http::handle_connection::<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>>}, ore::netio::stream::SniffingStream<tokio::net::tcp::stream::TcpStream>, ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, bool, impl core::future::future::Future, impl core::future::future::Future, (), bool, bool, &'t6 comm::switchboard::Switchboard<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>>, comm::switchboard::Switchboard<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>>, ore::netio::stream::SniffingStream<tokio::net::tcp::stream::TcpStream>, ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, impl core::future::future::Future, futures_util::future::try_future::err_into::ErrInto<impl core::future::future::Future, failure::error::Error>, futures_util::future::try_future::err_into::ErrInto<impl core::future::future::Future, failure::error::Error>, (), ore::netio::stream::SniffingStream<tokio::net::tcp::stream::TcpStream>, &'t7 mut ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, &'t8 [u8], &'t9 [u8; 17], tokio::io::util::write_all::WriteAll<'t10, ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>>, futures_util::future::try_future::map_ok::MapOk<tokio::io::util::write_all::WriteAll<'t11, ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>>, fn(())>, futures_util::future::try_future::err_into::ErrInto<futures_util::future::try_future::map_ok::MapOk<tokio::io::util::write_all::WriteAll<'t12, ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>>, fn(())>, failure::error::Error>, futures_util::future::try_future::err_into::ErrInto<futures_util::future::try_future::map_ok::MapOk<tokio::io::util::write_all::WriteAll<'t13, ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>>, fn(())>, failure::error::Error>, ()}` | |
| = note: required because it appears within the type `[static generator@src/materialized/lib.rs:91:3: 128:2 conn:tokio::net::tcp::stream::TcpStream, switchboard:comm::switchboard::Switchboard<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>>, cmd_tx:futures_channel::mpsc::UnboundedSender<coord::command::Command>, gather_metrics:bool for<'r, 's, 't0, 't1, 't2, 't3, 't4, 't5, 't6, 't7, 't8, 't9, 't10, 't11, 't12, 't13> {tokio::net::tcp::stream::TcpStream, comm::switchboard::Switchboard<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>>, futures_channel::mpsc::UnboundedSender<coord::command::Command>, bool, ore::netio::stream::SniffingStream<tokio::net::tcp::stream::TcpStream>, [u8; 8], for<'a> fn(&'a mut ore::netio::stream::SniffingStream<tokio::net::tcp::stream::TcpStream>, &'a mut [u8]) -> ore::netio::read_exact::ReadExactOrEof<'a, ore::netio::stream::SniffingStream<tokio::net::tcp::stream::TcpStream>> {ore::netio::read_exact::read_exact_or_eof::<ore::netio::stream::SniffingStream<tokio::net::tcp::stream::TcpStream>>}, ore::netio::stream::SniffingStream<tokio::net::tcp::stream::TcpStream>, &'r mut ore::netio::stream::SniffingStream<tokio::net::tcp::stream::TcpStream>, &'s mut ore::netio::stream::SniffingStream<tokio::net::tcp::stream::TcpStream>, [u8; 8], &'t0 mut [u8], &'t1 mut [u8; 8], ore::netio::read_exact::ReadExactOrEof<'t2, ore::netio::stream::SniffingStream<tokio::net::tcp::stream::TcpStream>>, ore::netio::read_exact::ReadExactOrEof<'t3, ore::netio::stream::SniffingStream<tokio::net::tcp::stream::TcpStream>>, (), usize, &'t4 [u8], [u8; 8], [u8], &'t5 [u8], bool, bool, fn(ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, futures_channel::mpsc::UnboundedSender<coord::command::Command>, bool) -> impl core::future::future::Future {pgwire::serve::<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>>}, ore::netio::stream::SniffingStream<tokio::net::tcp::stream::TcpStream>, ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, futures_channel::mpsc::UnboundedSender<coord::command::Command>, bool, impl core::future::future::Future, impl core::future::future::Future, (), bool, bool, fn(ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, bool) -> impl core::future::future::Future {http::handle_connection::<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>>}, ore::netio::stream::SniffingStream<tokio::net::tcp::stream::TcpStream>, ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, bool, impl core::future::future::Future, impl core::future::future::Future, (), bool, bool, &'t6 comm::switchboard::Switchboard<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>>, comm::switchboard::Switchboard<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>>, ore::netio::stream::SniffingStream<tokio::net::tcp::stream::TcpStream>, ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, impl core::future::future::Future, futures_util::future::try_future::err_into::ErrInto<impl core::future::future::Future, failure::error::Error>, futures_util::future::try_future::err_into::ErrInto<impl core::future::future::Future, failure::error::Error>, (), ore::netio::stream::SniffingStream<tokio::net::tcp::stream::TcpStream>, &'t7 mut ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, &'t8 [u8], &'t9 [u8; 17], tokio::io::util::write_all::WriteAll<'t10, ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>>, futures_util::future::try_future::map_ok::MapOk<tokio::io::util::write_all::WriteAll<'t11, ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>>, fn(())>, futures_util::future::try_future::err_into::ErrInto<futures_util::future::try_future::map_ok::MapOk<tokio::io::util::write_all::WriteAll<'t12, ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>>, fn(())>, failure::error::Error>, futures_util::future::try_future::err_into::ErrInto<futures_util::future::try_future::map_ok::MapOk<tokio::io::util::write_all::WriteAll<'t13, ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>>, fn(())>, failure::error::Error>, ()}]` | |
| = note: required because it appears within the type `std::future::GenFuture<[static generator@src/materialized/lib.rs:91:3: 128:2 conn:tokio::net::tcp::stream::TcpStream, switchboard:comm::switchboard::Switchboard<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>>, cmd_tx:futures_channel::mpsc::UnboundedSender<coord::command::Command>, gather_metrics:bool for<'r, 's, 't0, 't1, 't2, 't3, 't4, 't5, 't6, 't7, 't8, 't9, 't10, 't11, 't12, 't13> {tokio::net::tcp::stream::TcpStream, comm::switchboard::Switchboard<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>>, futures_channel::mpsc::UnboundedSender<coord::command::Command>, bool, ore::netio::stream::SniffingStream<tokio::net::tcp::stream::TcpStream>, [u8; 8], for<'a> fn(&'a mut ore::netio::stream::SniffingStream<tokio::net::tcp::stream::TcpStream>, &'a mut [u8]) -> ore::netio::read_exact::ReadExactOrEof<'a, ore::netio::stream::SniffingStream<tokio::net::tcp::stream::TcpStream>> {ore::netio::read_exact::read_exact_or_eof::<ore::netio::stream::SniffingStream<tokio::net::tcp::stream::TcpStream>>}, ore::netio::stream::SniffingStream<tokio::net::tcp::stream::TcpStream>, &'r mut ore::netio::stream::SniffingStream<tokio::net::tcp::stream::TcpStream>, &'s mut ore::netio::stream::SniffingStream<tokio::net::tcp::stream::TcpStream>, [u8; 8], &'t0 mut [u8], &'t1 mut [u8; 8], ore::netio::read_exact::ReadExactOrEof<'t2, ore::netio::stream::SniffingStream<tokio::net::tcp::stream::TcpStream>>, ore::netio::read_exact::ReadExactOrEof<'t3, ore::netio::stream::SniffingStream<tokio::net::tcp::stream::TcpStream>>, (), usize, &'t4 [u8], [u8; 8], [u8], &'t5 [u8], bool, bool, fn(ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, futures_channel::mpsc::UnboundedSender<coord::command::Command>, bool) -> impl core::future::future::Future {pgwire::serve::<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>>}, ore::netio::stream::SniffingStream<tokio::net::tcp::stream::TcpStream>, ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, futures_channel::mpsc::UnboundedSender<coord::command::Command>, bool, impl core::future::future::Future, impl core::future::future::Future, (), bool, bool, fn(ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, bool) -> impl core::future::future::Future {http::handle_connection::<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>>}, ore::netio::stream::SniffingStream<tokio::net::tcp::stream::TcpStream>, ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, bool, impl core::future::future::Future, impl core::future::future::Future, (), bool, bool, &'t6 comm::switchboard::Switchboard<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>>, comm::switchboard::Switchboard<ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>>, ore::netio::stream::SniffingStream<tokio::net::tcp::stream::TcpStream>, ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, impl core::future::future::Future, futures_util::future::try_future::err_into::ErrInto<impl core::future::future::Future, failure::error::Error>, futures_util::future::try_future::err_into::ErrInto<impl core::future::future::Future, failure::error::Error>, (), ore::netio::stream::SniffingStream<tokio::net::tcp::stream::TcpStream>, &'t7 mut ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>, &'t8 [u8], &'t9 [u8; 17], tokio::io::util::write_all::WriteAll<'t10, ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>>, futures_util::future::try_future::map_ok::MapOk<tokio::io::util::write_all::WriteAll<'t11, ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>>, fn(())>, futures_util::future::try_future::err_into::ErrInto<futures_util::future::try_future::map_ok::MapOk<tokio::io::util::write_all::WriteAll<'t12, ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>>, fn(())>, failure::error::Error>, futures_util::future::try_future::err_into::ErrInto<futures_util::future::try_future::map_ok::MapOk<tokio::io::util::write_all::WriteAll<'t13, ore::netio::stream::SniffedStream<tokio::net::tcp::stream::TcpStream>>, fn(())>, failure::error::Error>, ()}]>` | |
| = note: required because it appears within the type `impl core::future::future::Future` | |
| = note: required because it appears within the type `impl core::future::future::Future` | |
| error: aborting due to previous error | |
| For more information about this error, try `rustc --explain E0277`. | |
| error: could not compile `materialized`. | |
| To learn more, run the command again with --verbose. | |
| [~/Sites/materialize/materialize] (asyncawait *$ u=) | |
| benesch@langur$ |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment