Dan McDougall

Results 44 comments of 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.

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...