Skip to content

Commit

Permalink
add backward compatibility method
Browse files Browse the repository at this point in the history
  • Loading branch information
shekhirin committed Sep 6, 2024
1 parent 2f4ac1e commit e6d1d4c
Showing 1 changed file with 15 additions and 0 deletions.
15 changes: 15 additions & 0 deletions crates/exex/exex/src/manager.rs
Original file line number Diff line number Diff line change
Expand Up @@ -165,6 +165,21 @@ impl<Node> ExExNotifications<Node> {
Self { components, notifications }
}

/// Receives the next value for this receiver.
///
/// This method returns `None` if the channel has been closed and there are
/// no remaining messages in the channel's buffer. This indicates that no
/// further values can ever be received from this `Receiver`. The channel is
/// closed when all senders have been dropped, or when [`close`] is called.
///
/// For full documentation, see [`Receiver::recv`].
#[deprecated(
note = "use `ExExNotifications::poll_next` and its `Stream` implementation instead"
)]
pub async fn recv(&mut self) -> Option<ExExNotification> {
self.notifications.recv().await
}

// TODO(alexey): make it public when backfill is implemented in [`ExExNotificationsWithHead`]
/// Subscribe to notifications with the given head.
///
Expand Down

0 comments on commit e6d1d4c

Please sign in to comment.