Skip to content

Commit 3eca98b

Browse files
authored
fix(tracker): fix missing poll_flush (#27)
1 parent 468a26c commit 3eca98b

3 files changed

Lines changed: 6 additions & 6 deletions

File tree

src/server/tracker/inspector/http1.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -92,8 +92,8 @@ where
9292
}
9393

9494
#[inline]
95-
fn poll_flush(self: Pin<&mut Self>, _cx: &mut task::Context<'_>) -> Poll<io::Result<()>> {
96-
Poll::Ready(Ok(()))
95+
fn poll_flush(self: Pin<&mut Self>, cx: &mut task::Context<'_>) -> Poll<io::Result<()>> {
96+
self.project().inner.poll_flush(cx)
9797
}
9898

9999
#[inline]

src/server/tracker/inspector/http2/mod.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -101,8 +101,8 @@ where
101101
}
102102

103103
#[inline]
104-
fn poll_flush(self: Pin<&mut Self>, _cx: &mut task::Context<'_>) -> Poll<io::Result<()>> {
105-
Poll::Ready(Ok(()))
104+
fn poll_flush(self: Pin<&mut Self>, cx: &mut task::Context<'_>) -> Poll<io::Result<()>> {
105+
self.project().inner.poll_flush(cx)
106106
}
107107

108108
#[inline]

src/server/tracker/inspector/tls/mod.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -80,8 +80,8 @@ where
8080
}
8181

8282
#[inline]
83-
fn poll_flush(self: Pin<&mut Self>, _cx: &mut task::Context<'_>) -> Poll<io::Result<()>> {
84-
Poll::Ready(Ok(()))
83+
fn poll_flush(self: Pin<&mut Self>, cx: &mut task::Context<'_>) -> Poll<io::Result<()>> {
84+
self.project().inner.poll_flush(cx)
8585
}
8686

8787
#[inline]

0 commit comments

Comments
 (0)