Shuttle service integration for the Tower framework.
Example
use std::convert::Infallible;
use std::future::Future;
use std::pin::Pin;
use std::task::{Context, Poll};
#[derive(Clone)]
struct HelloWorld;
impl tower::Service<hyper::Request<hyper::Body>> for HelloWorld {
type Response = hyper::Response<hyper::Body>;
type Error = Infallible;
type Future = Pin<Box<dyn Future<Output = Result<Self::Response, Self::Error>> + Send + Sync>>;
fn poll_ready(&mut self, _cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> {
Poll::Ready(Ok(()))
}
fn call(&mut self, _req: hyper::Request<hyper::Body>) -> Self::Future {
let body = hyper::Body::from("Hello, world!");
let resp = hyper::Response::builder()
.status(200)
.body(body)
.expect("Unable to create the `hyper::Response` object");
let fut = async { Ok(resp) };
Box::pin(fut)
}
}
#[shuttle_runtime::main]
async fn tower() -> shuttle_tower::ShuttleTower<HelloWorld> {
let service = HelloWorld;
Ok(service.into())
}