diff options
author | Divy Srivastava <dj.srivastava23@gmail.com> | 2022-04-22 16:19:08 +0530 |
---|---|---|
committer | GitHub <noreply@github.com> | 2022-04-22 16:19:08 +0530 |
commit | 57f7e07c13a1a692602022af4fc32c6ac352bb72 (patch) | |
tree | e2b6bf271ebda2aecf158b25c9d6c466461549dd /ext/net/ops_tls.rs | |
parent | 2724235ec798f1fbf8fb5bd291615987ac4b919e (diff) |
Reland "perf(http): optimize ReadableStreams backed by a resource" (#14346)
Diffstat (limited to 'ext/net/ops_tls.rs')
-rw-r--r-- | ext/net/ops_tls.rs | 9 |
1 files changed, 6 insertions, 3 deletions
diff --git a/ext/net/ops_tls.rs b/ext/net/ops_tls.rs index d6b83e6e8..ca922203c 100644 --- a/ext/net/ops_tls.rs +++ b/ext/net/ops_tls.rs @@ -674,11 +674,11 @@ impl TlsStreamResource { pub async fn read( self: Rc<Self>, mut buf: ZeroCopyBuf, - ) -> Result<usize, AnyError> { + ) -> Result<(usize, ZeroCopyBuf), AnyError> { let mut rd = RcRef::map(&self, |r| &r.rd).borrow_mut().await; let cancel_handle = RcRef::map(&self, |r| &r.cancel_handle); let nread = rd.read(&mut buf).try_or_cancel(cancel_handle).await?; - Ok(nread) + Ok((nread, buf)) } pub async fn write( @@ -722,7 +722,10 @@ impl Resource for TlsStreamResource { "tlsStream".into() } - fn read(self: Rc<Self>, buf: ZeroCopyBuf) -> AsyncResult<usize> { + fn read_return( + self: Rc<Self>, + buf: ZeroCopyBuf, + ) -> AsyncResult<(usize, ZeroCopyBuf)> { Box::pin(self.read(buf)) } |