arc-reactor 0.2.4

Minimal, Asynchronous, Web Framework
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26

use futures::prelude::*;
use std::fs::Metadata;
use tokio::{fs::File, io::Error};

struct FileMeta(Option<File>);

impl Future for FileMeta {
	type Item = (File, Metadata);
	type Error = Error;
	fn poll(&mut self) -> Poll<Self::Item, Self::Error> {
		let mut file = self.0.take().unwrap();
		let metadata = match try!(file.poll_metadata()) {
			Async::Ready(m) => m,
			Async::NotReady => {
				self.0 = Some(file);
				return Ok(Async::NotReady);
			}
		};

		Ok(Async::Ready((file, metadata)))
	}
}

pub fn metadata(file: File) -> impl Future<Item = (File, Metadata), Error = Error> {
	FileMeta(Some(file))
}