Remove inner loop from io muxer

1 files changed, 14 insertions, 15 deletions

diff --git a/io_muxer.c b/io_muxer.c
index 17b32a9..4c4c0e2 100644
--- a/io_muxer.c
+++ b/io_muxer.c
@@ -87,22 +87,21 @@ bool IoMuxerOnWrite(struct IoMuxer* io_muxer, int fd, void (*fun)(void*),
 }
 
 enum IoMuxerResult IoMuxerIterate(struct IoMuxer* io_muxer, int timeout) {
-  for (;;) {
-    CompressRecords(io_muxer);
-    int result = poll(io_muxer->pfds, io_muxer->size, timeout);
-    switch (result) {
-      case -1:
-        return kIoMuxerResultError;
-      case 0:
-        return kIoMuxerResultTimeout;
-      default:
-        break;
-    }
-    for (size_t i = 0; i < io_muxer->size; i++) {
-      if (io_muxer->pfds[i].revents)
-        io_muxer->tasks[i].fun(io_muxer->tasks[i].user);
-    }
+  CompressRecords(io_muxer);
+  int result = poll(io_muxer->pfds, io_muxer->size, timeout);
+  switch (result) {
+    case -1:
+      return kIoMuxerResultError;
+    case 0:
+      return kIoMuxerResultTimeout;
+    default:
+      break;
+  }
+  for (size_t i = 0; i < io_muxer->size; i++) {
+    if (io_muxer->pfds[i].revents)
+      io_muxer->tasks[i].fun(io_muxer->tasks[i].user);
   }
+  return kIoMuxerResultSuccess;
 }
 
 void IoMuxerDestroy(struct IoMuxer* io_muxer) {