pub fn new(timeout_ms: u64) -> (Self, ConsensusNotificationListener) {
        let (notification_sender, notification_receiver) = mpsc::unbounded();

        let consensus_synchronizer = ConsensusNotifier {
            notification_sender,
            timeout_ms,
        };
        let consensus_listener = ConsensusNotificationListener::new(notification_receiver);
        (consensus_synchronizer, consensus_listener)
    }
/// Returns a new ConsensusNotifier and ConsensusNotificationListener (to be
/// used in conjuction with one another).
Returns a new ConsensusNotifier and ConsensusNotificationListener (to be
used in conjuction with one another).
Returns a new ConsensusNotifier and ConsensusNotificationListener ( to be used in conjuction with one another ) .
pub fn new(timeout_ms: u64) -> (Self, ConsensusNotificationListener) {
        let (notification_sender, notification_receiver) = mpsc::unbounded();
        let consensus_synchronizer = ConsensusNotifier {
            notification_sender,
            timeout_ms,
        };
        let consensus_listener = ConsensusNotificationListener::new(notification_receiver);
        (consensus_synchronizer, consensus_listener)
    }
pub fn new ( timeout_ms : u64 ) -> ( Self , ConsensusNotificationListener ) { let ( notification_sender , notification_receiver ) = mpsc :: unbounded ( ) ; let consensus_synchronizer = ConsensusNotifier { notification_sender , timeout_ms , } ; let consensus_listener = ConsensusNotificationListener :: new ( notification_receiver ) ; ( consensus_synchronizer , consensus_listener ) }
Returns a new ConsensusNotifier and ConsensusNotificationListener (to be
used in conjuction with one another).
Returns a new ConsensusNotifier and ConsensusNotificationListener ( to be used in conjuction with one another ) .
timeout_ms
u64