Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- extern crate tokio_core;
- extern crate mio;
- use mio::*;
- use std::io;
- use mio::unix::*;
- use std::net::TcpListener;
- use std::os::unix::prelude::*;
- use tokio_core::reactor::{Core, PollEvented};
- fn main() {
- let a = Core::new().unwrap();
- let b = Core::new().unwrap();
- let l = TcpListener::bind("127.0.0.1:0").unwrap();
- println!("{:?}", PollEvented::new(Custom(l.as_raw_fd()), &a.handle()));
- println!("{:?}", PollEvented::new(Custom(l.as_raw_fd()), &b.handle()));
- }
- #[derive(Debug)]
- struct Custom(i32);
- impl Evented for Custom {
- fn register(&self, poll: &Poll, token: Token, events: Ready, opts: PollOpt) -> io::Result<()> {
- EventedFd(&self.0).register(poll, token, events, opts)
- }
- fn reregister(&self, poll: &Poll, token: Token, events: Ready, opts: PollOpt) -> io::Result<()> {
- EventedFd(&self.0).reregister(poll, token, events, opts)
- }
- fn deregister(&self, poll: &Poll) -> io::Result<()> {
- EventedFd(&self.0).deregister(poll)
- }
- }
Add Comment
Please, Sign In to add comment