use crossbeam for other module
@@ -29,7 +29,7 @@ use tokio_timer::{clock, Delay};
use crate::helper::{select_topic, RpcMap, TransferType};
use crate::response::{BatchFutureResponse, PublishFutResponse, SingleFutureResponse};
use crate::service_error::ServiceError;
-
+use pubsub::channel;
type HyperResponse = hyper::Response<hyper::Body>;
#[derive(Debug)]
