[][src]Function fast_rpc::server::make_task

pub fn make_task<F>(
    socket: TcpStream,
    response_handler: F,
    log: Option<&Logger>
) -> impl Future<Item = (), Error = ()> + Send where
    F: FnMut(&FastMessage, &Logger) -> Result<Vec<FastMessage>, Error> + Send

Create a task to be used by the tokio runtime for handling responses to Fast protocol requests.