|
1 |
| -use futures_core::future::BoxFuture; |
2 | 1 | use std::borrow::Cow;
|
3 | 2 | use std::ops::{Deref, DerefMut};
|
4 | 3 |
|
| 4 | +use futures_core::future::BoxFuture; |
5 | 5 | use futures_core::stream::BoxStream;
|
| 6 | + |
6 | 7 | use sqlx_core::bytes::{BufMut, Bytes};
|
7 | 8 |
|
8 | 9 | use crate::connection::PgConnection;
|
9 | 10 | use crate::error::{Error, Result};
|
10 | 11 | use crate::ext::async_stream::TryAsyncStream;
|
11 |
| -use crate::io::{AsyncRead, AsyncReadExt}; |
| 12 | +use crate::io::AsyncRead; |
12 | 13 | use crate::message::{
|
13 | 14 | CommandComplete, CopyData, CopyDone, CopyFail, CopyResponse, MessageFormat, Query,
|
14 | 15 | };
|
@@ -45,7 +46,7 @@ impl PgConnection {
|
45 | 46 | ///
|
46 | 47 | /// 1. by closing the connection, or:
|
47 | 48 | /// 2. by using another connection to kill the server process that is sending the data as shown
|
48 |
| - /// [in this StackOverflow answer](https://stackoverflow.com/a/35319598). |
| 49 | + /// [in this StackOverflow answer](https://stackoverflow.com/a/35319598). |
49 | 50 | ///
|
50 | 51 | /// If you don't read the stream to completion, the next time the connection is used it will
|
51 | 52 | /// need to read and discard all the remaining queued data, which could take some time.
|
@@ -98,7 +99,7 @@ pub trait PgPoolCopyExt {
|
98 | 99 | ///
|
99 | 100 | /// 1. by closing the connection, or:
|
100 | 101 | /// 2. by using another connection to kill the server process that is sending the data as shown
|
101 |
| - /// [in this StackOverflow answer](https://stackoverflow.com/a/35319598). |
| 102 | + /// [in this StackOverflow answer](https://stackoverflow.com/a/35319598). |
102 | 103 | ///
|
103 | 104 | /// If you don't read the stream to completion, the next time the connection is used it will
|
104 | 105 | /// need to read and discard all the remaining queued data, which could take some time.
|
|
0 commit comments