diff --git a/src/main.rs b/src/main.rs
index 97a1398..de77b6c 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -122,10 +122,8 @@ impl FSKReceiver {
     fn new(eye_sender: Sender<Vec<f32>>) -> Self {
         let samples_per_symbol = (SAMPLE_RATE as f32) / (BAUD_RATE as f32);
 
-        let mut phase_lowpass = FIRFilter::new(&vec![
-            Complex32::new(1., 0.);
-            samples_per_symbol as usize / 2
-        ]);
+        let mut phase_lowpass =
+            FIRFilter::new(&vec![Complex32::new(1., 0.); samples_per_symbol as usize]);
         phase_lowpass.normalize_dc();
         //let mut dc_block = DCBlocker::new(0.999);
         //let mut dc_block = DCBlocker::new(1.);
@@ -255,7 +253,7 @@ impl Transceiver {
                             {
                                 match recv.as_mut().unwrap().receive(iq).await
                                 {
-                                    Ok(Some(Frame::Data(_))) => {println!("GOT DATA"); send_ack = false; recv = None; state_tx.try_send(TransceiverState::EOT);},
+                                    Ok(Some(Frame::Data(dat))) => {rx_stream_sender.try_send(dat); println!("GOT DATA"); send_ack = false; recv = None; state_tx.try_send(TransceiverState::EOT);},
                                     //Ok(Some(Frame::Ack)) => {current_message = None; recv = None; state_tx.try_send(TransceiverState::EOT);},
                                     Err(()) => {recv = None;},
                                     _ => {}