1 files changed, 2 insertions, 0 deletions
diff --git a/ringbuf.c b/ringbuf.c
index 29301e5..2c58752 100644
--- a/ringbuf.c
+++ b/ringbuf.c
@@ -1,5 +1,6 @@
 #include "ringbuf.h"
 
+#include <pthread.h>
 #include <string.h>
 
 void RingBuffer_init(RingBuffer *self, size_t size) {
@@ -46,6 +47,7 @@ void RingBuffer_end(RingBuffer *self) {
     pthread_mutex_lock(&self->mutex);
     self->finished_flag = true;
     pthread_mutex_unlock(&self->mutex);
+    pthread_cond_signal(&self->not_empty_cond);
 }
 
 size_t RingBuffer_write(RingBuffer *self, const uint8_t *data, size_t len) {