Add NotificationQueue for priority notifications

[mkatychev]

NotificationManager now features a NotificationQueue struct for priority notifications:

rex-sm/src/notification.rs

Lines 92 to 110 in 58a1c8a

	#[derive(Default, Clone, Debug)]
	pub struct NotificationQueue<M: RexMessage>(pub(crate) Arc<StreamableDeque<Notification<M>>>);
	impl<M: RexMessage> NotificationQueue<M> {
	pub fn new() -> Self {
	Self(Arc::new(StreamableDeque::new()))
	}
	pub fn send(&self, notif: Notification<M>) {
	self.0.push_back(notif)
	}
	pub fn priority_send(&self, notif: Notification<M>) {
	self.0.push_front(notif)
	}
	pub fn stream(&self) -> StreamReceiver<Notification<M>> {
	self.0.stream()
	}
	}

• Moved RexBuilder into separate module
• Added RexBuilder::with_ingress_adapter method:
  

  rex-sm/src/builder.rs

  Lines 227 to 251 in cf3291d

  	pub fn with_ingress_adapter(
  	mut self,
  	state_routers: Vec<BoxedStateRouter<K, In>>,
  	ingress_topic: <K::Message as RexMessage>::Topic,
  	) -> Self {
  	assert!(!state_routers.is_empty());
  	let (tx, rx) = self
  	.ingress_channel
  	.take()
  	.expect("ingress_channel uninitialized");
  	let outbound_tx = self
  	.outbound_tx
  	.clone()
  	.expect("builder outbound_tx uninitialized");
  	let ingress_adapter = IngressAdapter {
  	signal_queue: self.signal_queue.clone(),
  	outbound_tx,
  	router: PacketRouter::new(state_routers),
  	inbound_tx: tx,
  	inbound_rx: Some(rx),
  	topic: ingress_topic,
  	};
  	self.with_np(ingress_adapter)
  	}

[mergify]

[✅] @mkatychev: Add NotificationQueue for priority notifications has been merged successfully.