Struct cocaine::service::app::App [−][src]
pub struct App { /* fields omitted */ }Application service wrapper.
Methods
impl App[src]
impl Apppub fn new(service: Service) -> Self[src]
pub fn new(service: Service) -> SelfConstructs 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.