diff --git a/tokio-postgres/src/copy_out.rs b/tokio-postgres/src/copy_out.rs index f5d52429..999afac8 100644 --- a/tokio-postgres/src/copy_out.rs +++ b/tokio-postgres/src/copy_out.rs @@ -39,6 +39,7 @@ async fn start(client: &InnerClient, buf: Bytes) -> Result { Ok(responses) } +/// A stream of `COPY ... TO STDOUT` query data. pub struct CopyStream { responses: Responses, } diff --git a/tokio-postgres/src/lib.rs b/tokio-postgres/src/lib.rs index df531af0..f5636521 100644 --- a/tokio-postgres/src/lib.rs +++ b/tokio-postgres/src/lib.rs @@ -114,6 +114,7 @@ pub use crate::simple_query::SimpleQueryStream; #[cfg(feature = "runtime")] pub use crate::socket::Socket; pub use crate::statement::{Column, Statement}; +pub use crate::copy_out::CopyStream; #[cfg(feature = "runtime")] use crate::tls::MakeTlsConnect; pub use crate::tls::NoTls;