Link error

Author: alexcrichton

http/src/lib.rs

@@ -57,8 +57,9 @@ pub fn serve<Req, Resp, S>(addr: &SocketAddr, s: S)
         .and_then(move |listener| {
             listener.incoming().map(move |(stream, _)| {
                 handle(stream, service.clone())
-            }).map_err(From::from).buffered(8).for_each(|()| Ok(()))
-        });
+            }).boxed().map_err(From::from).buffered(8).for_each(|()| Ok(()))
+        })
+    .boxed();
     lp.run(listen)
 }
 
@@ -75,7 +76,7 @@ fn handle<Req, Resp, S>(stream: TcpStream, service: Arc<S>)
 
     let input = ParseStream::new(read, stream.ready_read)
         .map_err(From::from);
-    let responses = input.and_then(move |req| service.process(req));
+    let responses = input.boxed().and_then(move |req| service.process(req)).boxed();
     let output = StreamWriter::new(write, stream.ready_write, responses);
 
     output.boxed()

src/stream/buffered.rs

@@ -23,7 +23,7 @@ pub fn new<S>(s: S, amt: usize) -> Buffered<S>
           S::Item: IntoFuture<Error=<S as Stream>::Error>,
 {
     Buffered {
-        stream: s.fuse(),
+        stream: super::fuse::new(s),
         futures: (0..amt).map(|_| None).collect(),
     }
 }