introduce tokio-threadpool

Author: David Barsky

Cargo.lock

@@ -9,7 +9,8 @@ use http::{
     HeaderMap, Method, Request as HttpRequest,
 };
 use serde::{
-    de::{Error as DeError, MapAccess, Visitor}, Deserialize, Deserializer
+    de::{Error as DeError, MapAccess, Visitor},
+    Deserialize, Deserializer,
 };
 use serde_json::Value;
 

lambda-http/src/request.rs

@@ -9,7 +9,7 @@ use http::{
 };
 use serde::{
     ser::{Error as SerError, SerializeMap},
-    Serializer, Serialize, Deserialize
+    Deserialize, Serialize, Serializer,
 };
 
 use crate::body::Body;

lambda-http/src/response.rs

@@ -6,7 +6,7 @@ use std::{
 
 use serde::{
     de::{MapAccess, Visitor},
-    Deserialize, Deserializer
+    Deserialize, Deserializer,
 };
 
 /// A read-only view into a map of string data which may contain multiple values

lambda-http/src/strmap.rs

@@ -11,6 +11,7 @@ futures = "^0.1"
 hyper = "^0.12"
 http = "^0.1"
 tokio = "^0.1"
+tokio-threadpool = "^0.1"
 envy = "0.3"
 tower-service = { version = "0.2", git = "https://github.com/tower-rs/tower.git" }
 tower-retry = { version = "0.1", git = "https://github.com/tower-rs/tower.git" }

lambda-runtime-client-simple/Cargo.toml

@@ -1,5 +1,5 @@
 use bytes::Bytes;
-use simple_lambda_runtime::{Error, lambda};
+use simple_lambda_runtime::{lambda, Error};
 
 fn main() {
     let handler = |event: Bytes| -> Result<Bytes, Error> { unimplemented!() };

lambda-runtime-client-simple/examples/basic.rs

@@ -4,10 +4,11 @@ extern crate serde_derive;
 use crate::{hyper_tower::*, settings::Config};
 use bytes::{buf::FromBuf, Bytes, IntoBuf};
 use futures::{
-    future::{result, FutureResult},
+    future::{poll_fn, result, FutureResult},
     Async, Future, Poll,
 };
 use http::{Method, Request, Response, Uri};
+use tokio_threadpool::blocking;
 use tower_service::Service;
 use tower_util::ServiceFn;
 
@@ -74,9 +75,11 @@ where
         .next_event()
         .and_then(move |event| {
             let body = event.into_body();
-            f.run(body)
+            poll_fn(move || {
+                blocking(|| f.run(body.clone()))
+            }).map_err(|_| panic!("the threadpool shut down"))
         })
-        .then(move |res| match res {
+        .and_then(move |res| match res {
             Ok(bytes) => runtime.ok_response(bytes),
             Err(e) => runtime.err_response(Bytes::from(catch(e))),
         })