mirror of
https://github.com/lune-org/lune.git
synced 2025-05-04 10:43:57 +01:00
Avoid some cloning
This commit is contained in:
parent
47d5f928b8
commit
37da9a39ec
1 changed files with 6 additions and 6 deletions
|
@ -32,12 +32,9 @@ impl HyperService<HyperRequest<Incoming>> for Service {
|
||||||
type Future = Pin<Box<dyn Future<Output = Result<Self::Response, Self::Error>>>>;
|
type Future = Pin<Box<dyn Future<Output = Result<Self::Response, Self::Error>>>>;
|
||||||
|
|
||||||
fn call(&self, req: HyperRequest<Incoming>) -> Self::Future {
|
fn call(&self, req: HyperRequest<Incoming>) -> Self::Future {
|
||||||
let lua = self.lua.clone();
|
|
||||||
let address = self.address;
|
|
||||||
let config = self.config.clone();
|
|
||||||
|
|
||||||
if is_upgrade_request(&req) {
|
if is_upgrade_request(&req) {
|
||||||
if let Some(handler) = config.handle_web_socket {
|
if let Some(handler) = self.config.handle_web_socket.clone() {
|
||||||
|
let lua = self.lua.clone();
|
||||||
return Box::pin(async move {
|
return Box::pin(async move {
|
||||||
let response = match make_upgrade_response(&req) {
|
let response = match make_upgrade_response(&req) {
|
||||||
Ok(res) => res,
|
Ok(res) => res,
|
||||||
|
@ -63,8 +60,11 @@ impl HyperService<HyperRequest<Incoming>> for Service {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
let lua = self.lua.clone();
|
||||||
|
let address = self.address;
|
||||||
|
let handler = self.config.handle_request.clone();
|
||||||
Box::pin(async move {
|
Box::pin(async move {
|
||||||
match handle_request(lua.clone(), config.handle_request, req, address).await {
|
match handle_request(lua, handler, req, address).await {
|
||||||
Ok(response) => Ok(response),
|
Ok(response) => Ok(response),
|
||||||
Err(_err) => {
|
Err(_err) => {
|
||||||
// TODO: Propagare the error somehow?
|
// TODO: Propagare the error somehow?
|
||||||
|
|
Loading…
Add table
Reference in a new issue