Posted Sun, 23 Apr 2017 14:18:49 GMT in reply to yawniek
On Thu, 20 Apr 2017 16:33:16 GMT, yawniek wrote:
i'm trying to make librdkafka-d work nicely with vibe-d.
it has an interface that sends payload of size_t into a filedescriptor
so that after that you can consume the messages.
do i need to open a socket myself?
or how would i intergrate that with vibe.d ?
As far as I understand, you could either create a non-blocking socket pair manually, and then use
FileDescriptorEvent.Trigger.read on the reader socket to be able to wait for events. Alternatively, on Linux, a single descriptor created with
eventfd should also work.