From 22ea1bf7b1eacea3cb25a717992536ab58195bbb Mon Sep 17 00:00:00 2001 From: Aiden McClelland Date: Mon, 12 Apr 2021 20:56:24 -0600 Subject: [PATCH] remove phantom --- rpc-toolkit-macro-internals/src/rpc_server/build.rs | 4 ++-- rpc-toolkit/src/rpc_server_helpers.rs | 10 ++-------- 2 files changed, 4 insertions(+), 10 deletions(-) diff --git a/rpc-toolkit-macro-internals/src/rpc_server/build.rs b/rpc-toolkit-macro-internals/src/rpc_server/build.rs index f8c982d..97e814e 100644 --- a/rpc-toolkit-macro-internals/src/rpc_server/build.rs +++ b/rpc-toolkit-macro-internals/src/rpc_server/build.rs @@ -22,7 +22,7 @@ pub fn build(args: RpcServerArgs) -> TokenStream { { let ctx = #ctx; let status_fn = #status_fn; - let (builder, ctx_phantom) = rpc_toolkit::rpc_server_helpers::make_builder(&ctx); + let builder = rpc_toolkit::rpc_server_helpers::make_builder(&ctx); let make_svc = rpc_toolkit::hyper::service::make_service_fn(move |_| { let ctx = ctx.clone(); async move { @@ -36,7 +36,7 @@ pub fn build(args: RpcServerArgs) -> TokenStream { Ok(rpc_req) => Ok(( rpc_req.id, #command( - rpc_toolkit::rpc_server_helpers::bind_type(ctx_phantom, ctx), + ctx, rpc_toolkit::yajrc::RpcMethod::as_str(&rpc_req.method), rpc_req.params, ) diff --git a/rpc-toolkit/src/rpc_server_helpers.rs b/rpc-toolkit/src/rpc_server_helpers.rs index d619a01..a9ef7cf 100644 --- a/rpc-toolkit/src/rpc_server_helpers.rs +++ b/rpc-toolkit/src/rpc_server_helpers.rs @@ -1,5 +1,3 @@ -use std::marker::PhantomData; - use hyper::body::Buf; use hyper::server::conn::AddrIncoming; use hyper::server::{Builder, Server}; @@ -20,18 +18,14 @@ lazy_static! { serde_json::to_vec(&RpcResponse::>::from(yajrc::INTERNAL_ERROR)).unwrap(); } -pub fn make_builder(ctx: &Ctx) -> (Builder, PhantomData) { +pub fn make_builder(ctx: &Ctx) -> Builder { let addr = match ctx.host() { Host::Ipv4(ip) => (ip, ctx.port()).into(), Host::Ipv6(ip) => (ip, ctx.port()).into(), Host::Domain(localhost) if localhost == "localhost" => ([127, 0, 0, 1], ctx.port()).into(), _ => ([0, 0, 0, 0], ctx.port()).into(), }; - (Server::bind(&addr), PhantomData) -} - -pub fn bind_type(_phantom: PhantomData, actual: T) -> T { - actual + Server::bind(&addr) } pub async fn make_request Deserialize<'de> + 'static>(