Dan McDougall
Dan McDougall
I've made some progress here. Something inside of tokio is doing something that results in "Error: Invalid argument (os error 22)" which causes the `incoming()` method to throw an error...
The file descriptor coming out of xcb is a Unix Socket. I looked at the `tokio-uds` package on Github but there was no documentation and no examples so I wasn't...
Actually, I'm not sure *what* the file descriptor points to. It's whatever I get back from `xcb::ffi::base::xcb_get_file_descriptor(conn.get_raw_conn());` I *assume* it's a socket because XCB can work over a network.
I was able to finagle the code into using tokio-uds but I get the same exact error, "Error: Invalid argument (os error 22)". Wish it was more descriptive!
I'm totally lost at this point as to how to get tokio to work like it does with mio. I thought it might be helpful to post the mio equivalent...
I'm not sure what you mean? I'm only calling `accept` on the actual socket. Not on the XCBEVENT token part.
How do I do the equivalent in Tokio though?
Replacing: let xcb_handler = xcb_fd_listener.incoming() .for_each(move |(_socket, _welcome)| { ...with: let xcb_handler = xcb_fd_listener.incoming() .and_then(move |(_socket, _welcome)| { Results in compilation errors: error[E0277]: the trait bound `futures::stream::MapErr: futures::Future` is not...
I have an idea... Maybe the problem is that something is calling `accept()` on that TcpListener (or UnixListener) when it shouldn't (that will always result in an error). Is there...
@alexcrichton I have no idea what I'm doing (haha)... Can you point me to a minimal example of a `PollEvented` implementation I can use as a base? I figure I...