fix: wasm trait bounds

Author: levydsa

libsql/src/hrana/stream.rs

@@ -2,13 +2,12 @@ use crate::hrana::cursor::{Cursor, CursorReq};
 use crate::hrana::proto::{Batch, BatchResult, DescribeResult, Stmt, StmtResult};
 use crate::hrana::{CursorResponseError, HranaError, HttpSend, Result};
 use bytes::{Bytes, BytesMut};
-use futures::{Stream, StreamExt};
+use futures::Stream;
 use libsql_hrana::proto::{
     BatchStreamReq, CloseSqlStreamReq, CloseStreamReq, CloseStreamResp, DescribeStreamReq,
     GetAutocommitStreamReq, PipelineReqBody, PipelineRespBody, SequenceStreamReq,
     StoreSqlStreamReq, StreamRequest, StreamResponse, StreamResult,
 };
-use std::pin::pin;
 use std::sync::atomic::{AtomicBool, AtomicI64, AtomicU64, Ordering};
 use std::sync::Arc;
 use tokio::sync::Mutex;

libsql/src/wasm/mod.rs

@@ -48,7 +48,7 @@ cfg_cloudflare! {
 #[derive(Debug, Clone)]
 pub struct Connection<T>
 where
-    T: HttpSend,
+    T: HttpSend + Sync + Send + 'static,
 {
     conn: HttpConnection<T>,
 }
@@ -65,7 +65,7 @@ cfg_cloudflare! {
 
 impl<T> Connection<T>
 where
-    T: HttpSend,
+    T: HttpSend + Sync + Send + 'static,
     <T as HttpSend>::Stream: 'static,
 {
     pub async fn execute(&self, sql: &str, params: impl IntoParams) -> crate::Result<u64> {
@@ -126,14 +126,14 @@ where
 #[derive(Debug, Clone)]
 pub struct Transaction<T>
 where
-    T: HttpSend,
+    T: HttpSend + Sync + Send + 'static,
 {
     inner: HttpTransaction<T>,
 }
 
 impl<T> Transaction<T>
 where
-    T: HttpSend,
+    T: HttpSend + Sync + Send + 'static,
     <T as HttpSend>::Stream: 'static,
 {
     pub async fn query(&self, sql: &str, params: impl IntoParams) -> crate::Result<Rows> {

libsql/src/wasm/rows.rs

@@ -1,4 +1,5 @@
 use crate::hrana::HranaRows;
+use crate::hrana::HttpSend;
 use crate::Row;
 use bytes::Bytes;
 use futures::Stream;
@@ -42,8 +43,9 @@ pub(super) trait RowsInner {
 }
 
 #[async_trait::async_trait(?Send)]
-impl<S> RowsInner for HranaRows<S>
+impl<S, T> RowsInner for HranaRows<S, T>
 where
+    T: HttpSend + Sync + Send + 'static,
     S: Stream<Item = std::io::Result<Bytes>> + Unpin,
 {
     async fn next(&mut self) -> crate::Result<Option<Row>> {