From 9f25fdf929a3903e1608f4bf1f043100b9cf353d Mon Sep 17 00:00:00 2001 From: Nikolay Kim Date: Mon, 4 Mar 2019 14:31:46 -0800 Subject: [PATCH] rename StreamServiceFactory to ServiceFactory --- actix-server/CHANGES.md | 9 +++++++++ actix-server/src/builder.rs | 6 +++--- actix-server/src/lib.rs | 5 ++++- actix-server/src/services.rs | 10 +++++----- 4 files changed, 21 insertions(+), 9 deletions(-) diff --git a/actix-server/CHANGES.md b/actix-server/CHANGES.md index 127ea9ae..01e44401 100644 --- a/actix-server/CHANGES.md +++ b/actix-server/CHANGES.md @@ -1,5 +1,14 @@ # Changes +## [0.3.1] - 2019-03-xx + +### Changed + +* Rename `StreamServiceFactory` to `ServiceFactory` + +* Deprecate `StreamServiceFactory` + + ## [0.3.0] - 2019-03-02 ### Changed diff --git a/actix-server/src/builder.rs b/actix-server/src/builder.rs index 124c3fd6..7e1fe007 100644 --- a/actix-server/src/builder.rs +++ b/actix-server/src/builder.rs @@ -14,7 +14,7 @@ use tokio_timer::sleep; use crate::accept::{AcceptLoop, AcceptNotify, Command}; use crate::config::{ConfiguredService, ServiceConfig}; use crate::server::{Server, ServerCommand}; -use crate::services::{InternalServiceFactory, StreamNewService, StreamServiceFactory}; +use crate::services::{InternalServiceFactory, ServiceFactory, StreamNewService}; use crate::signals::{Signal, Signals}; use crate::worker::{self, Worker, WorkerAvailability, WorkerClient}; use crate::Token; @@ -137,7 +137,7 @@ impl ServerBuilder { /// Add new service to the server. pub fn bind>(mut self, name: N, addr: U, factory: F) -> io::Result where - F: StreamServiceFactory, + F: ServiceFactory, U: net::ToSocketAddrs, { let sockets = bind_addr(addr)?; @@ -163,7 +163,7 @@ impl ServerBuilder { factory: F, ) -> Self where - F: StreamServiceFactory, + F: ServiceFactory, { let token = self.token.next(); self.services.push(StreamNewService::create( diff --git a/actix-server/src/lib.rs b/actix-server/src/lib.rs index d1165e0b..fe8765e2 100644 --- a/actix-server/src/lib.rs +++ b/actix-server/src/lib.rs @@ -13,7 +13,10 @@ mod worker; pub use self::builder::ServerBuilder; pub use self::config::{ServiceConfig, ServiceRuntime}; pub use self::server::Server; -pub use self::services::StreamServiceFactory; +pub use self::services::ServiceFactory; + +#[doc(hidden)] +pub use self::services::ServiceFactory as StreamServiceFactory; /// Socket id token #[derive(Clone, Copy, Debug, PartialEq, Eq, Hash)] diff --git a/actix-server/src/services.rs b/actix-server/src/services.rs index a629b667..2aaf998d 100644 --- a/actix-server/src/services.rs +++ b/actix-server/src/services.rs @@ -22,7 +22,7 @@ pub(crate) enum ServerMessage { ForceShutdown, } -pub trait StreamServiceFactory: Send + Clone + 'static { +pub trait ServiceFactory: Send + Clone + 'static { type NewService: NewService; fn create(&self) -> Self::NewService; @@ -92,7 +92,7 @@ where } } -pub(crate) struct StreamNewService { +pub(crate) struct StreamNewService { name: String, inner: F, token: Token, @@ -100,7 +100,7 @@ pub(crate) struct StreamNewService { impl StreamNewService where - F: StreamServiceFactory, + F: ServiceFactory, { pub(crate) fn create(name: String, token: Token, inner: F) -> Box { Box::new(Self { name, token, inner }) @@ -109,7 +109,7 @@ where impl InternalServiceFactory for StreamNewService where - F: StreamServiceFactory, + F: ServiceFactory, { fn name(&self, _: Token) -> &str { &self.name @@ -152,7 +152,7 @@ impl InternalServiceFactory for Box { } } -impl StreamServiceFactory for F +impl ServiceFactory for F where F: Fn() -> T + Send + Clone + 'static, T: NewService,