1 2 3 4 5 6 7 8 9 10 11 12
use crate::io::AsyncStreamExt; use sqlx_core::Error; pub(crate) trait StreamDecode<Context = ()> where Self: Sized, { async fn decode_with<S: AsyncStreamExt>( stream: &mut S, context: Context, ) -> Result<Self, Error>; }