diff --git a/examples/example_hyper.rs b/examples/example_hyper.rs
index c9d02bc..a6eda1b 100644
--- a/examples/example_hyper.rs
+++ b/examples/example_hyper.rs
@@ -16,9 +16,7 @@ extern crate lazy_static;
 #[macro_use]
 extern crate prometheus;
 
-use hyper::header::ContentType;
-use hyper::mime::Mime;
-use hyper::server::{Request, Response, Server};
+use hyper::{header::CONTENT_TYPE, rt::Future, service::service_fn_ok, Body, Response, Server};
 
 use prometheus::{Counter, Encoder, Gauge, HistogramVec, TextEncoder};
 
@@ -44,24 +42,35 @@ lazy_static! {
 }
 
 fn main() {
-    let encoder = TextEncoder::new();
-    let addr = "127.0.0.1:9898";
-    println!("listening addr {:?}", addr);
-    Server::http(addr)
-        .unwrap()
-        .handle(move |_: Request<'_, '_>, mut res: Response<'_>| {
+    let addr = ([127, 0, 0, 1], 9898).into();
+    println!("Listening address: {:?}", addr);
+
+    let new_service = || {
+        let encoder = TextEncoder::new();
+        service_fn_ok(move |_request| {
             HTTP_COUNTER.inc();
             let timer = HTTP_REQ_HISTOGRAM.with_label_values(&["all"]).start_timer();
 
             let metric_families = prometheus::gather();
             let mut buffer = vec![];
             encoder.encode(&metric_families, &mut buffer).unwrap();
-            res.headers_mut()
-                .set(ContentType(encoder.format_type().parse::<Mime>().unwrap()));
-            res.send(&buffer).unwrap();
+            HTTP_BODY_GAUGE.set(buffer.len() as f64);
+
+            let response = Response::builder()
+                .status(200)
+                .header(CONTENT_TYPE, encoder.format_type())
+                .body(Body::from(buffer))
+                .unwrap();
 
             timer.observe_duration();
-            HTTP_BODY_GAUGE.set(buffer.len() as f64);
+
+            response
         })
-        .unwrap();
+    };
+
+    let server = Server::bind(&addr)
+        .serve(new_service)
+        .map_err(|e| eprintln!("Server error: {}", e));
+
+    hyper::rt::run(server);
 }