@@ -16,14 +16,22 @@ const DEFAULT_PORT: u16 = 5432;
1616/// Connect to postgres server with a tls connector.
1717///
1818/// ```rust
19- /// use async_postgres::connect;
20- ///
19+ /// use async_postgres::connect_tls;
20+ /// use native_tls::{Certificate, TlsConnector};
21+ /// use postgres_native_tls::MakeTlsConnector;
22+ /// use std::fs;
2123/// use std::error::Error;
2224/// use async_std::task::spawn;
2325///
2426/// async fn play() -> Result<(), Box<dyn Error>> {
25- /// let url = "host=localhost user=postgres";
26- /// let (client, conn) = connect(url.parse()?).await?;
27+ /// let cert = fs::read("database_cert.pem")?;
28+ /// let cert = Certificate::from_pem(&cert)?;
29+ /// let connector = TlsConnector::builder()
30+ /// .add_root_certificate(cert)
31+ /// .build()?;
32+ /// let connector = MakeTlsConnector::new(connector);
33+ /// let url = "host=localhost user=postgres sslmode=require";
34+ /// let (client, conn) = connect_tls(url.parse()?, connector).await?;
2735/// spawn(conn);
2836/// let row = client.query_one("SELECT * FROM user WHERE id=$1", &[&0]).await?;
2937/// let value: &str = row.get(0);
@@ -91,7 +99,7 @@ async fn connect_socket(
9199 Host :: Tcp ( tcp) => {
92100 let fut = TcpStream :: connect ( ( tcp. as_str ( ) , port) ) ;
93101 let socket = timeout ( dur, fut) . await ?;
94- socket. set_nodelay ( true ) ?;
102+ // socket.set_nodelay(true)?;
95103 Ok ( socket. into ( ) )
96104 }
97105 }
0 commit comments