Skip to content

Commit

Permalink
core/muxing: Introduce StreamMuxerEvent::map_inbound_stream (#2691)
Browse files Browse the repository at this point in the history
Co-authored-by: Max Inden <mail@max-inden.de>
  • Loading branch information
thomaseizinger and mxinden committed Jun 15, 2022
1 parent 04f31cd commit 3c120ef
Show file tree
Hide file tree
Showing 4 changed files with 25 additions and 17 deletions.
6 changes: 6 additions & 0 deletions core/CHANGELOG.md
@@ -1,3 +1,9 @@
# 0.33.1 - unreleased

- Introduce `StreamMuxerEvent::map_inbound_stream`. See [PR 2691].

[PR 2691]: https://github.com/libp2p/rust-libp2p/pull/2691

# 0.33.0

- Have methods on `Transport` take `&mut self` instead of `self`. See [PR 2529].
Expand Down
2 changes: 1 addition & 1 deletion core/Cargo.toml
Expand Up @@ -3,7 +3,7 @@ name = "libp2p-core"
edition = "2021"
rust-version = "1.56.1"
description = "Core traits and structs of libp2p"
version = "0.33.0"
version = "0.33.1"
authors = ["Parity Technologies <admin@parity.io>"]
license = "MIT"
repository = "https://github.com/libp2p/rust-libp2p"
Expand Down
24 changes: 8 additions & 16 deletions core/src/either.rs
Expand Up @@ -210,22 +210,14 @@ where
cx: &mut Context<'_>,
) -> Poll<Result<StreamMuxerEvent<Self::Substream>, Self::Error>> {
match self {
EitherOutput::First(inner) => inner.poll_event(cx).map(|result| {
result.map_err(|e| e.into()).map(|event| match event {
StreamMuxerEvent::AddressChange(addr) => StreamMuxerEvent::AddressChange(addr),
StreamMuxerEvent::InboundSubstream(substream) => {
StreamMuxerEvent::InboundSubstream(EitherOutput::First(substream))
}
})
}),
EitherOutput::Second(inner) => inner.poll_event(cx).map(|result| {
result.map_err(|e| e.into()).map(|event| match event {
StreamMuxerEvent::AddressChange(addr) => StreamMuxerEvent::AddressChange(addr),
StreamMuxerEvent::InboundSubstream(substream) => {
StreamMuxerEvent::InboundSubstream(EitherOutput::Second(substream))
}
})
}),
EitherOutput::First(inner) => inner
.poll_event(cx)
.map_err(|e| e.into())
.map_ok(|event| event.map_inbound_stream(EitherOutput::First)),
EitherOutput::Second(inner) => inner
.poll_event(cx)
.map_err(|e| e.into())
.map_ok(|event| event.map_inbound_stream(EitherOutput::Second)),
}
}

Expand Down
10 changes: 10 additions & 0 deletions core/src/muxing.rs
Expand Up @@ -236,6 +236,16 @@ impl<T> StreamMuxerEvent<T> {
None
}
}

/// Map the stream within [`StreamMuxerEvent::InboundSubstream`] to a new type.
pub fn map_inbound_stream<O>(self, map: impl FnOnce(T) -> O) -> StreamMuxerEvent<O> {
match self {
StreamMuxerEvent::InboundSubstream(stream) => {
StreamMuxerEvent::InboundSubstream(map(stream))
}
StreamMuxerEvent::AddressChange(addr) => StreamMuxerEvent::AddressChange(addr),
}
}
}

/// Polls for an event from the muxer and, if an inbound substream, wraps this substream in an
Expand Down

0 comments on commit 3c120ef

Please sign in to comment.