Commit 33916d23 authored by Theodore Ni's avatar Theodore Ni Committed by Yt
Browse files

vector: compatibility with rust 1.71

parent ad566c44
Loading
Loading
Loading
Loading
+4 −0
Original line number Diff line number Diff line
@@ -45,6 +45,10 @@ rustPlatform.buildRustPackage {
    hash = "sha256-+ATOHx+LQLQV4nMdj1FRRvDTqGCTbX9kl290AbY9Vw0=";
  };

  patches = [
    ./rust-1.71-unnecessary-mut.diff
  ];

  cargoLock = {
    lockFile = ./Cargo.lock;
    outputHashes = {
+22 −0
Original line number Diff line number Diff line
diff --git a/lib/vector-core/src/tls/incoming.rs b/lib/vector-core/src/tls/incoming.rs
index 5d2fd1cdb..7992f2c2b 100644
--- a/lib/vector-core/src/tls/incoming.rs
+++ b/lib/vector-core/src/tls/incoming.rs
@@ -263,7 +263,7 @@ impl MaybeTlsIncomingStream<TcpStream> {
     where
         F: FnOnce(Pin<&mut MaybeTlsStream<TcpStream>>, &mut Context) -> Poll<io::Result<T>>,
     {
-        let mut this = self.get_mut();
+        let this = self.get_mut();
         loop {
             return match &mut this.state {
                 StreamState::Accepted(stream) => poll_fn(Pin::new(stream), cx),
@@ -307,7 +307,7 @@ impl AsyncWrite for MaybeTlsIncomingStream<TcpStream> {
     }
 
     fn poll_shutdown(self: Pin<&mut Self>, cx: &mut Context) -> Poll<io::Result<()>> {
-        let mut this = self.get_mut();
+        let this = self.get_mut();
         match &mut this.state {
             StreamState::Accepted(stream) => match Pin::new(stream).poll_shutdown(cx) {
                 Poll::Ready(Ok(())) => {