diff --git a/src/pulsecore/protocol-native.c b/src/pulsecore/protocol-native.c
index f64c190a568488d94b8c18df88be08ee0040bc91..f6c9d2da2987cce9842f19c6de6ab2ff46f726ad 100644
--- a/src/pulsecore/protocol-native.c
+++ b/src/pulsecore/protocol-native.c
@@ -3967,6 +3967,8 @@ static void command_flush_record_stream(pa_pdispatch *pd, uint32_t command, uint
     CHECK_VALIDITY(c->pstream, s, tag, PA_ERR_NOENTITY);
 
     pa_memblockq_flush_read(s->memblockq);
+    pa_memblockq_flush_read(s->source_output->thread_info.delay_memblockq);
+    pa_resampler_reset(s->source_output->thread_info.resampler);
     pa_pstream_send_simple_ack(c->pstream, tag);
 }