Use with tokio

[gmilleramilar]

Sorry if this is the wrong place for this question/request, but I'm wondering if this can be used with Tokio. It seems like something would have to implement AsyncRead and/or AsyncWrite. Can you provide an example or pointers on how this might be done?

[tormol]

You have to create a new struct containing some tokio type. In tokio 0.2 this would be tokio::io::PollEvented<PosixMq> with the queue opened in nonblocking mode, but that has likely changed in 1.0.
an example with tokio 0.2 from one of my other crates

Since priority can't be passed through the tokio traits, you could maybe add a field in the struct for it and expose a getter and setter.

Thanks in advance :)

[yorickdewid]

Maybe include an example in the examples directory? I'd reckon many will use tokio in combination with mio.