remove unnecessary messages

Author: jeff-davis

tokio-postgres/src/replication_client.rs

@@ -293,14 +293,6 @@ impl ReplicationClient {
             Message::DataRow(m) => m,
             m => return Err(Error::unexpected_message(m)),
         };
-        match responses.next().await? {
-            Message::CommandComplete(_) => (),
-            m => return Err(Error::unexpected_message(m)),
-        };
-        match responses.next().await? {
-            Message::ReadyForQuery(_) => (),
-            m => return Err(Error::unexpected_message(m)),
-        };
 
         let fields = rowdesc.fields().collect::<Vec<_>>().map_err(Error::parse)?;
         let ranges = datarow.ranges().collect::<Vec<_>>().map_err(Error::parse)?;
@@ -345,14 +337,6 @@ impl ReplicationClient {
             Message::DataRow(m) => m,
             m => return Err(Error::unexpected_message(m)),
         };
-        match responses.next().await? {
-            Message::CommandComplete(_) => (),
-            m => return Err(Error::unexpected_message(m)),
-        };
-        match responses.next().await? {
-            Message::ReadyForQuery(_) => (),
-            m => return Err(Error::unexpected_message(m)),
-        };
 
         let fields = rowdesc.fields().collect::<Vec<_>>().map_err(Error::parse)?;
         let ranges = datarow.ranges().collect::<Vec<_>>().map_err(Error::parse)?;
@@ -379,14 +363,6 @@ impl ReplicationClient {
             Message::DataRow(m) => m,
             m => return Err(Error::unexpected_message(m)),
         };
-        match responses.next().await? {
-            Message::CommandComplete(_) => (),
-            m => return Err(Error::unexpected_message(m)),
-        };
-        match responses.next().await? {
-            Message::ReadyForQuery(_) => (),
-            m => return Err(Error::unexpected_message(m)),
-        };
 
         let fields = rowdesc.fields().collect::<Vec<_>>().map_err(Error::parse)?;
         let ranges = datarow.ranges().collect::<Vec<_>>().map_err(Error::parse)?;
@@ -436,14 +412,6 @@ impl ReplicationClient {
             Message::DataRow(m) => m,
             m => return Err(Error::unexpected_message(m)),
         };
-        match responses.next().await? {
-            Message::CommandComplete(_) => (),
-            m => return Err(Error::unexpected_message(m)),
-        };
-        match responses.next().await? {
-            Message::ReadyForQuery(_) => (),
-            m => return Err(Error::unexpected_message(m)),
-        };
 
         let fields = rowdesc.fields().collect::<Vec<_>>().map_err(Error::parse)?;
         let ranges = datarow.ranges().collect::<Vec<_>>().map_err(Error::parse)?;
@@ -507,14 +475,6 @@ impl ReplicationClient {
             Message::DataRow(m) => m,
             m => return Err(Error::unexpected_message(m)),
         };
-        match responses.next().await? {
-            Message::CommandComplete(_) => (),
-            m => return Err(Error::unexpected_message(m)),
-        };
-        match responses.next().await? {
-            Message::ReadyForQuery(_) => (),
-            m => return Err(Error::unexpected_message(m)),
-        };
 
         let fields = rowdesc.fields().collect::<Vec<_>>().map_err(Error::parse)?;
         let ranges = datarow.ranges().collect::<Vec<_>>().map_err(Error::parse)?;