Commitd6c9d63

committed

fix tests and compilation errors

1 parent24937c0 commitd6c9d63Copy full SHA for d6c9d63

File tree

+17

-5

lines changed

+17

-5

lines changed

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -19,7 +19,7 @@ use crate::{`
`19`	`19`	`use bytes::{Buf,BytesMut};`
`20`	`20`	`use fallible_iterator::FallibleIterator;`
`21`	`21`	`use futures_channel::mpsc;`
`22`		`-use futures_util::{StreamExt,TryStreamExt};`
	`22`	`+use futures_util::{pin_mut,StreamExt,TryStreamExt};`
`23`	`23`	`use parking_lot::Mutex;`
`24`	`24`	`use postgres_protocol::message::backend::Message;`
`25`	`25`	`use postgres_protocol::message::frontend;`

Lines changed: 16 additions & 4 deletions

Original file line number	Diff line number	Diff line change
`@@ -914,12 +914,18 @@ async fn query_typed_one() {`
`914`	`914`	`.unwrap();`
`915`	`915`
`916`	`916`	`client`
`917`		`-.query_typed_one("SELECT * FROM foo WHERE name = 'dave'",&[])`
	`917`	`+.query_typed_one(`
	`918`	`+"SELECT * FROM foo WHERE name = $1",`
	`919`	`+&[(&"dave",Type::TEXT)],`
	`920`	`+)`
`918`	`921`	`.await`
`919`	`922`	`.err()`
`920`	`923`	`.unwrap();`
`921`	`924`	`client`
`922`		`-.query_typed_one("SELECT * FROM foo WHERE name = 'alice'",&[])`
	`925`	`+.query_typed_one(`
	`926`	`+"SELECT * FROM foo WHERE name = $1",`
	`927`	`+&[(&"alice",Type::TEXT)],`
	`928`	`+)`
`923`	`929`	`.await`
`924`	`930`	`.unwrap();`
`925`	`931`	`client`
`@@ -978,12 +984,18 @@ async fn query_typed_opt() {`
`978`	`984`	`.unwrap();`
`979`	`985`
`980`	`986`	`assert!(client`
`981`		`-.query_typed_opt("SELECT * FROM foo WHERE name = 'dave'",&[])`
	`987`	`+.query_typed_opt(`
	`988`	`+"SELECT * FROM foo WHERE name = $1",`
	`989`	`+&[(&"dave",Type::TEXT)]`
	`990`	`+)`
`982`	`991`	`.await`
`983`	`992`	`.unwrap()`
`984`	`993`	`.is_none());`
`985`	`994`	`client`
`986`		`-.query_typed_opt("SELECT * FROM foo WHERE name = 'alice'",&[])`
	`995`	`+.query_typed_opt(`
	`996`	`+"SELECT * FROM foo WHERE name = $1",`
	`997`	`+&[(&"alice",Type::TEXT)],`
	`998`	`+)`
`987`	`999`	`.await`
`988`	`1000`	`.unwrap()`
`989`	`1001`	`.unwrap();`

Comments

(0)