dnim/rust-postgres
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Remove debugging printlns from copy out protocol

Browse Source
This commit is contained in:
Nikhil Benesch 2019-12-25 11:12:34 -05:00
parent a8fa2a42c0
commit 6d18d7955e
No known key found for this signature in database
GPG Key ID: FCF98542083C5A69
1 changed files with 0 additions and 3 deletions

3
tokio-postgres/src/copy_out.rs
View File

@ -25,13 +25,11 @@ pub async fn copy_out(client: &InnerClient, statement: Statement) -> Result<Copy
async fn start(client: &InnerClient, buf: Bytes) -> Result<Responses, Error> { async fn start(client: &InnerClient, buf: Bytes) -> Result<Responses, Error> {
let mut responses = client.send(RequestMessages::Single(FrontendMessage::Raw(buf)))?; let mut responses = client.send(RequestMessages::Single(FrontendMessage::Raw(buf)))?;
println!("a");
match responses.next().await? { match responses.next().await? {
Message::BindComplete => {} Message::BindComplete => {}
_ => return Err(Error::unexpected_message()), _ => return Err(Error::unexpected_message()),
} }
println!("b");
match responses.next().await? { match responses.next().await? {
Message::CopyOutResponse(_) => {} Message::CopyOutResponse(_) => {}
_ => return Err(Error::unexpected_message()), _ => return Err(Error::unexpected_message()),
@ -55,7 +53,6 @@ impl Stream for CopyOutStream {
fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> { fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> {
let this = self.project(); let this = self.project();
println!("c");
match ready!(this.responses.poll_next(cx)?) { match ready!(this.responses.poll_next(cx)?) {
Message::CopyData(body) => Poll::Ready(Some(Ok(body.into_bytes()))), Message::CopyData(body) => Poll::Ready(Some(Ok(body.into_bytes()))),
Message::CopyDone => Poll::Ready(None), Message::CopyDone => Poll::Ready(None),