diff --git a/muxers/mplex/src/lib.rs b/muxers/mplex/src/lib.rs index c1626ba0..39ed99ae 100644 --- a/muxers/mplex/src/lib.rs +++ b/muxers/mplex/src/lib.rs @@ -533,7 +533,7 @@ where C: AsyncRead + AsyncWrite } fn shutdown_substream(&self, sub: &mut Self::Substream, _: Shutdown) -> Poll<(), IoError> { - let elem = codec::Elem::Reset { + let elem = codec::Elem::Close { substream_id: sub.num, endpoint: sub.endpoint, };