diff --git a/full-node/sov-sequencer/tests/tx_status_subscription_rpc.rs b/full-node/sov-sequencer/tests/tx_status_subscription_rpc.rs
index 50622e30a..285c16816 100644
--- a/full-node/sov-sequencer/tests/tx_status_subscription_rpc.rs
+++ b/full-node/sov-sequencer/tests/tx_status_subscription_rpc.rs
@@ -93,10 +93,7 @@ async fn subscribe() {
     client.send_transactions(txs, None).await.unwrap();
 
     let tx_status = subscription.next().await.unwrap().unwrap();
-    assert!(matches!(
-        tx_status,
-        TxStatus::Submitted | TxStatus::Published { .. }
-    ));
+    assert!(matches!(tx_status, TxStatus::Submitted));
     let tx_status = subscription.next().await.unwrap().unwrap();
     assert!(matches!(tx_status, TxStatus::Published { .. }));
 
diff --git a/rollup-interface/src/node/services/da.rs b/rollup-interface/src/node/services/da.rs
index 5e8880daf..723017e15 100644
--- a/rollup-interface/src/node/services/da.rs
+++ b/rollup-interface/src/node/services/da.rs
@@ -31,9 +31,8 @@ pub trait DaService: Send + Sync + 'static {
     >;
 
     /// Type that allow to consume [`futures::Stream`] of BlockHeaders.
-    type HeaderStream: futures::Stream<
-        Item = Result<<Self::Spec as DaSpec>::BlockHeader, Self::Error>,
-    >;
+    type HeaderStream: futures::Stream<Item = Result<<Self::Spec as DaSpec>::BlockHeader, Self::Error>>
+        + Send;
 
     /// A transaction ID, used to identify the transaction in the DA layer.
     type TransactionId: PartialEq + Eq + PartialOrd + Ord + core::hash::Hash;