mercuryworkshop-mirror/epoxy-tls
1
0
Fork 0
mirror of https://github.com/MercuryWorkshop/epoxy-tls.git synced 2025-05-12 14:00:01 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

sink<&[u8]> is basically useless, don't accept

Browse source
This commit is contained in:
Toshit Chawda 2024-09-26 19:18:08 -07:00
parent 888044f63d
commit b602b38c47
No known key found for this signature in database
GPG key ID: 91480ED99E2B3D9D
1 changed files with 3 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

6
wisp/src/stream.rs
View file

@ -552,7 +552,7 @@ impl MuxStreamIoSink {
} }
} }
impl Sink<&[u8]> for MuxStreamIoSink { impl Sink<BytesMut> for MuxStreamIoSink {
type Error = std::io::Error; type Error = std::io::Error;
fn poll_ready(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { fn poll_ready(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> {
self.project() self.project()
@ -560,10 +560,10 @@ impl Sink<&[u8]> for MuxStreamIoSink {
.poll_ready(cx) .poll_ready(cx)
.map_err(std::io::Error::other) .map_err(std::io::Error::other)
} }
fn start_send(self: Pin<&mut Self>, item: &[u8]) -> Result<(), Self::Error> { fn start_send(self: Pin<&mut Self>, item: BytesMut) -> Result<(), Self::Error> {
self.project() self.project()
.tx .tx
.start_send(Payload::Bytes(BytesMut::from(item))) .start_send(Payload::Bytes(item))
.map_err(std::io::Error::other) .map_err(std::io::Error::other)
} }
fn poll_flush(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { fn poll_flush(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> {