diff --git a/pallas-multiplexer/src/mux.rs b/pallas-multiplexer/src/mux.rs
index 3d80588..4d7f779 100644
--- a/pallas-multiplexer/src/mux.rs
+++ b/pallas-multiplexer/src/mux.rs
@@ -44,7 +44,7 @@ where
     }
 
     pub fn tick(&mut self) -> TickOutcome {
-        match self.ingress.recv_timeout(Duration::from_millis(500)) {
+        match self.ingress.recv_timeout(Duration::from_millis(1)) {
             Ok((id, payload)) => {
                 let segment = Segment::new(self.clock, id, payload);
 
diff --git a/pallas-upstream/src/framework.rs b/pallas-upstream/src/framework.rs
index 0c63f06..dcccaba 100644
--- a/pallas-upstream/src/framework.rs
+++ b/pallas-upstream/src/framework.rs
@@ -51,7 +51,7 @@ impl multiplexer::agents::Channel for ProtocolChannel {
     }
 
     fn dequeue_chunk(&mut self) -> Result<multiplexer::Payload, multiplexer::agents::ChannelError> {
-        match self.2.recv_or_idle() {
+        match self.2.recv() {
             Ok(msg) => Ok(msg.payload),
             Err(error) => {
                 error!(?error, "dequeue chunk failed");