github/reth
1
1
Fork 0
mirror of https://github.com/paradigmxyz/reth.git synced 2026-01-27 08:08:15 -05:00
Code Issues Packages Projects Releases Wiki Activity

chore: use rx over tx for receiver name (#14693)

Browse Source
This commit is contained in:
Hai | RISE
2025-02-25 15:45:55 +07:00
committed by GitHub
parent 4204b993fc
commit 7267395b11
2 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
crates/net/network/src/session/active.rs
View File

@@ -97,7 +97,7 @@ pub(crate) struct ActiveSession<N: NetworkPrimitives> {
/// A message that needs to be delivered to the session manager
pub(crate) pending_message_to_session: Option<ActiveSessionMessage<N>>,
/// Incoming internal requests which are delegated to the remote peer.
pub(crate) internal_request_tx: Fuse<ReceiverStream<PeerRequest<N>>>,
pub(crate) internal_request_rx: Fuse<ReceiverStream<PeerRequest<N>>>,
/// All requests sent to the remote peer we're waiting on a response
pub(crate) inflight_requests: FxHashMap<u64, InflightRequest<PeerRequest<N>>>,
/// All requests that were sent by the remote peer and we're waiting on an internal response
@@ -547,7 +547,7 @@ impl<N: NetworkPrimitives> Future for ActiveSession<N> {
let deadline = this.request_deadline();
while let Poll::Ready(Some(req)) = this.internal_request_tx.poll_next_unpin(cx) {
while let Poll::Ready(Some(req)) = this.internal_request_rx.poll_next_unpin(cx) {
progress = true;
this.on_internal_peer_request(req, deadline);
}
@@ -960,7 +960,7 @@ mod tests {
"network_active_session",
),
pending_message_to_session: None,
internal_request_tx: ReceiverStream::new(messages_rx).fuse(),
internal_request_rx: ReceiverStream::new(messages_rx).fuse(),
inflight_requests: Default::default(),
conn,
queued_outgoing: QueuedOutgoingMessages::new(Gauge::noop()),

2
crates/net/network/src/session/mod.rs
View File

@@ -521,7 +521,7 @@ impl<N: NetworkPrimitives> SessionManager<N> {
commands_rx: ReceiverStream::new(commands_rx),
to_session_manager: self.active_session_tx.clone(),
pending_message_to_session: None,
internal_request_tx: ReceiverStream::new(messages_rx).fuse(),
internal_request_rx: ReceiverStream::new(messages_rx).fuse(),
inflight_requests: Default::default(),
conn,
queued_outgoing: QueuedOutgoingMessages::new(