Posted Sun, 23 Apr 2017 14:18:49 GMT in reply to
yawniek
Reply
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.
see: https://github.com/edenhill/librdkafka/blob/master/src/rdkafka.h#L1946
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 createFileDescriptorEvent
with 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.