Struct cocaine::service::app::App [−][src]
pub struct App { /* fields omitted */ }
Application service wrapper.
Methods
impl App
[src]
impl App
pub fn new(service: Service) -> Self
[src]
pub fn new(service: Service) -> Self
Constructs an application service wrapper using the specified service.
pub fn enqueue(
&self,
event: &str
) -> impl Future<Item = (Sender, UnboundedReceiver<Result<String, Error>>), Error = Error>
[src]
pub fn enqueue(
&self,
event: &str
) -> impl Future<Item = (Sender, UnboundedReceiver<Result<String, Error>>), Error = Error>
Enqueues an event, opening a bidirectional stream on success.