Move pub/sub to it's own module
This commit is contained in:
parent
08c63536c4
commit
ec49c28425
@ -1,14 +1,12 @@
|
|||||||
mod broker_task;
|
mod broker_task;
|
||||||
mod message;
|
mod message;
|
||||||
mod publication;
|
mod pub_sub;
|
||||||
mod subscription;
|
|
||||||
|
|
||||||
use broker_task::{
|
use broker_task::{
|
||||||
AdvertiseRequest, BrokerError, BrokerRequestSender, BrokerResult, BrokerTask, SubscribeRequest,
|
AdvertiseRequest, BrokerError, BrokerRequestSender, BrokerResult, BrokerTask, SubscribeRequest,
|
||||||
};
|
};
|
||||||
pub use message::Message;
|
pub use message::Message;
|
||||||
pub use publication::{Publication, PublishError};
|
pub use pub_sub::*;
|
||||||
pub use subscription::{Subscription, SubscriptionError};
|
|
||||||
|
|
||||||
use futures::executor::block_on;
|
use futures::executor::block_on;
|
||||||
use tokio::sync::oneshot;
|
use tokio::sync::oneshot;
|
||||||
|
5
src/pub_sub/mod.rs
Normal file
5
src/pub_sub/mod.rs
Normal file
@ -0,0 +1,5 @@
|
|||||||
|
mod publication;
|
||||||
|
mod subscription;
|
||||||
|
|
||||||
|
pub use publication::{Publication, PublishError};
|
||||||
|
pub use subscription::{Subscription, SubscriptionError};
|
Loading…
x
Reference in New Issue
Block a user