Struct FnUpstream 

pub struct FnUpstream<F> { /* private fields */ }

Wrapper that adapts an async function to the Upstream trait.

This allows any async function or closure to be used as the upstream data source in the hitbox caching FSM.

Example

use hitbox_fn::FnUpstream;

async fn fetch_data(id: u64) -> Data {
    // fetch from database
}

let upstream = FnUpstream::new(fetch_data);

Implementations

impl<F> FnUpstream<F>

pub fn new(func: F) -> Self

Create a new function upstream wrapper.

Trait Implementations

impl<F, Args, Fut, Res> Upstream<Args> for FnUpstream<F>

where F: FnMut(Args) -> Fut, Fut: Future<Output = Res> + Send,

type Response = Res

The response type returned by the upstream service

type Future = Fut

The future that resolves to the response

fn call(&mut self, req: Args) -> Self::Future

Call the upstream service with the given request