David Blewett
David Blewett
Here is an example: http://lbolla.info/blog/2013/03/21/chat-postgres-ioloop .
You could use cffi: https://caremad.io/2015/06/distributing-a-cffi-project-redux/ http://cffi.readthedocs.org/en/latest/cdef.html .
Chiming in here; `net::udp_socket::tests::multi_executor_bind_works` seems to hang every time for me (when running the whole test suite, whole test suite with 1 thread and just the single test). I have...
@BurntSushi is this something you would like me to help with? I can probably help with 1-3; not sure about 4.
@benesch I pinged upstream on that ticket. It seems like it might be awhile before this is available, however. I think we could make use of Tokio's blocking executor in...
@benesch I decided to start work on adding async wrappers on the Rust side. I'm taking the approach of 2 new traits: `rdkafka::consumer::AsyncConsumer` and `rdkafka::producer::AsyncProducer` to mirror the sync versions....
@guilload I started working on this, but haven't been able to get back to it. I would be happy to review if you want to work on it.
I just wanted to chime in here, on the lack of access to `BaseConsumer.poll()` from `StreamConsumer`. I found that if I didn't have a simple loop that called `BaseConsumer.poll`, the...
@vojtechkral I'd be very interested to see what you have. Can you make it available somewhere?
@tzachshabtay can you provide a self contained example of what you have tried?