pub struct FailingRuntimeStreamAdapter;Expand description
RuntimeStreamAdapter that always fails. Used by tests asserting a
failed publish does not panic the runtime bridge.
Implementations§
Trait Implementations§
Source§impl Clone for FailingRuntimeStreamAdapter
impl Clone for FailingRuntimeStreamAdapter
Source§fn clone(&self) -> FailingRuntimeStreamAdapter
fn clone(&self) -> FailingRuntimeStreamAdapter
Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreimpl Copy for FailingRuntimeStreamAdapter
Source§impl Debug for FailingRuntimeStreamAdapter
impl Debug for FailingRuntimeStreamAdapter
Source§impl Default for FailingRuntimeStreamAdapter
impl Default for FailingRuntimeStreamAdapter
Source§fn default() -> FailingRuntimeStreamAdapter
fn default() -> FailingRuntimeStreamAdapter
Returns the “default value” for a type. Read more
Source§impl RuntimeStreamAdapter for FailingRuntimeStreamAdapter
impl RuntimeStreamAdapter for FailingRuntimeStreamAdapter
Source§fn publish<'life0, 'async_trait>(
&'life0 self,
_room: RuntimeRoom,
_event: RuntimeEventEnvelope,
) -> Pin<Box<dyn Future<Output = Result<(), RuntimeStreamError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn publish<'life0, 'async_trait>(
&'life0 self,
_room: RuntimeRoom,
_event: RuntimeEventEnvelope,
) -> Pin<Box<dyn Future<Output = Result<(), RuntimeStreamError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Best-effort fanout of
event to all live subscribers of room.Source§fn subscribe<'life0, 'async_trait>(
&'life0 self,
_room: RuntimeRoom,
) -> Pin<Box<dyn Future<Output = Result<BoxRuntimeEventStream, RuntimeStreamError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn subscribe<'life0, 'async_trait>(
&'life0 self,
_room: RuntimeRoom,
) -> Pin<Box<dyn Future<Output = Result<BoxRuntimeEventStream, RuntimeStreamError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Subscribes to the live event stream for
room.Auto Trait Implementations§
impl Freeze for FailingRuntimeStreamAdapter
impl RefUnwindSafe for FailingRuntimeStreamAdapter
impl Send for FailingRuntimeStreamAdapter
impl Sync for FailingRuntimeStreamAdapter
impl Unpin for FailingRuntimeStreamAdapter
impl UnsafeUnpin for FailingRuntimeStreamAdapter
impl UnwindSafe for FailingRuntimeStreamAdapter
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