1 files changed, 20 insertions, 0 deletions
diff --git a/src/libunixonacid/textmessage_handle.c b/src/libunixonacid/textmessage_handle.c
new file mode 100644
index 0000000..bec62cb
--- /dev/null
+++ b/src/libunixonacid/textmessage_handle.c
@@ -0,0 +1,20 @@
+/* ISC license. */
+
+#include <sys/uio.h>
+#include <skalibs/textmessage.h>
+
+int textmessage_handle (textmessage_receiver_t *tr, textmessage_handler_func_t_ref f, void *p)
+{
+  unsigned int count = 0 ;
+  while (count < TEXTMESSAGE_MAXREADS || textmessage_receiver_hasmsginbuf(tr))
+  {
+    struct iovec v ;
+    int r = textmessage_receive(tr, &v) ;
+    if (r < 0) return -1 ;
+    if (!r) break ;
+    r = (*f)(&v, p) ;
+    if (r <= 0) return r-2 ;
+    count++ ;
+  }
+  return (int)count ;
+}