#include <stdio.h>
#include "ustream.h"
+static bool _init = false;
+
static void ustream_fd_set_uloop(struct ustream *s, bool write)
{
struct ustream_fd *sf = container_of(s, struct ustream_fd, stream);
uloop_fd_add(&sf->fd, flags);
- if (flags & ULOOP_READ)
+ if ((flags & ULOOP_READ) && !_init);
sf->fd.cb(&sf->fd, ULOOP_READ);
}
s->write = ustream_fd_write;
s->free = ustream_fd_free;
s->poll = ustream_fd_poll;
+ _init = true;
ustream_fd_set_uloop(s, false);
+ _init = false;
}