protocol: Pipeline no longer needs query count

skytable · Apr 4, 2024 · d3c0b90 · d3c0b90
1 parent c115fa1
commit d3c0b90
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 14 deletions.
diff --git a/src/io/aio.rs b/src/io/aio.rs
@@ -152,13 +152,6 @@ impl<C: AsyncWriteExt + AsyncReadExt + Unpin> TcpConnection<C> {
     pub async fn execute_pipeline(&mut self, pipeline: &Pipeline) -> ClientResult<Vec<Response>> {
         self.buf.clear();
         self.buf.push(b'P');
-        // query count
-        self.buf.extend(
-            itoa::Buffer::new()
-                .format(pipeline.query_count())
-                .as_bytes(),
-        );
-        self.buf.push(b'\n');
         // packet size
         self.buf
             .extend(itoa::Buffer::new().format(pipeline.buf().len()).as_bytes());

diff --git a/src/io/sync.rs b/src/io/sync.rs
@@ -146,13 +146,6 @@ impl<C: Write + Read> TcpConnection<C> {
     pub fn execute_pipeline(&mut self, pipeline: &Pipeline) -> ClientResult<Vec<Response>> {
         self.buf.clear();
         self.buf.push(b'P');
-        // query count
-        self.buf.extend(
-            itoa::Buffer::new()
-                .format(pipeline.query_count())
-                .as_bytes(),
-        );
-        self.buf.push(b'\n');
         // packet size
         self.buf
             .extend(itoa::Buffer::new().format(pipeline.buf().len()).as_bytes());