pub struct WsConsumer { /* private fields */ }Implementations§
Source§impl WsConsumer
impl WsConsumer
pub fn new(cfg: WsServerConfig) -> Self
Trait Implementations§
Source§impl Consumer for WsConsumer
impl Consumer for WsConsumer
Source§fn start<'life0, 'async_trait>(
&'life0 mut self,
ctx: ConsumerContext,
) -> Pin<Box<dyn Future<Output = Result<(), CamelError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn start<'life0, 'async_trait>(
&'life0 mut self,
ctx: ConsumerContext,
) -> Pin<Box<dyn Future<Output = Result<(), CamelError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Start consuming messages, sending them through the provided context.
Source§fn stop<'life0, 'async_trait>(
&'life0 mut self,
) -> Pin<Box<dyn Future<Output = Result<(), CamelError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn stop<'life0, 'async_trait>(
&'life0 mut self,
) -> Pin<Box<dyn Future<Output = Result<(), CamelError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Stop consuming messages.
Source§fn concurrency_model(&self) -> ConcurrencyModel
fn concurrency_model(&self) -> ConcurrencyModel
Declares this consumer’s natural concurrency model. Read more
Auto Trait Implementations§
impl Freeze for WsConsumer
impl !RefUnwindSafe for WsConsumer
impl Send for WsConsumer
impl Sync for WsConsumer
impl Unpin for WsConsumer
impl UnsafeUnpin for WsConsumer
impl !UnwindSafe for WsConsumer
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more