23 lines
1,008 B
Diff
23 lines
1,008 B
Diff
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(())) => {
|