We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent c85ec3d commit 1952db3Copy full SHA for 1952db3
1 file changed
libsql/src/hrana/stream.rs
@@ -329,16 +329,6 @@ where
329
self.pipeline_url = Arc::from(format!("{base_url}/v3/pipeline"));
330
self.cursor_url = Arc::from(format!("{base_url}/v3/cursor"));
331
}
332
- match response.baton.take() {
333
- None => {
334
- tracing::trace!("client stream has been closed by the server");
335
- self.reset();
336
- } // stream has been closed by the server
337
- Some(baton) => {
338
- tracing::trace!("client stream has been assigned with baton: `{}`", baton);
339
- self.baton = Some(baton)
340
- }
341
342
Ok(cursor)
343
344
0 commit comments