diff --git a/src/bridge/HostBridge.cpp b/src/bridge/HostBridge.cpp
index 6408f09c..dc476e0a 100644
--- a/src/bridge/HostBridge.cpp
+++ b/src/bridge/HostBridge.cpp
@@ -106,6 +106,7 @@ void audioCallback(ma_device* device, void* output, const void* input, ma_uint32
     if (bridge->m_outputAudio.dataSize() >= AUDIO_SAMPLES_LENGTH) {
         short samples[AUDIO_SAMPLES_LENGTH];
         bridge->m_outputAudio.get(samples, AUDIO_SAMPLES_LENGTH);
+
         uint8_t* pcm = (uint8_t*)output;
         int pcmIdx = 0;
         for (uint32_t smpIdx = 0; smpIdx < AUDIO_SAMPLES_LENGTH; smpIdx++) {
@@ -307,6 +308,12 @@ HostBridge::~HostBridge()
         m_rtsPttController = nullptr;
     }
 
+    if (m_ctsCorController != nullptr) {
+        m_ctsCorController->close();
+        delete m_ctsCorController;
+        m_ctsCorController = nullptr;
+    }
+
     delete[] m_ambeBuffer;
     delete[] m_netLDU1;
     delete[] m_netLDU2;
@@ -1630,6 +1637,10 @@ uint8_t* HostBridge::generateRTPHeaders(uint8_t msgLen, uint16_t& rtpSeq)
     header.setSequence(rtpSeq);
     header.setSSRC(m_network->getPeerId());
 
+    // set the marker for the start of a stream
+    if (rtpSeq == 0U)
+        header.setMarker(true);
+
     uint8_t* buffer = new uint8_t[RTP_HEADER_LENGTH_BYTES + msgLen];
     ::memset(buffer, 0x00U, RTP_HEADER_LENGTH_BYTES + msgLen);