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.