pub struct CompositeSubscriptionRuntime { /* private fields */ }Expand description
Store-backed composite subscription runtime dispatching event and projection routes.
Implementations§
Source§impl CompositeSubscriptionRuntime
impl CompositeSubscriptionRuntime
Sourcepub fn new(
store: SubscriptionStore,
registry: SubscriptionRegistry,
config: SubscriptionRuntimeConfig,
) -> Self
pub fn new( store: SubscriptionStore, registry: SubscriptionRegistry, config: SubscriptionRuntimeConfig, ) -> Self
Build a store-backed composite subscription runtime.
Trait Implementations§
Source§impl Clone for CompositeSubscriptionRuntime
impl Clone for CompositeSubscriptionRuntime
Source§fn clone(&self) -> CompositeSubscriptionRuntime
fn clone(&self) -> CompositeSubscriptionRuntime
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 moreSource§impl SubscriptionSessionFactory for CompositeSubscriptionRuntime
impl SubscriptionSessionFactory for CompositeSubscriptionRuntime
Source§fn open_session(
&self,
subscription_id: &str,
resume_cursor: Option<&[u8]>,
client_window: u32,
control_rx: Receiver<SessionControl>,
) -> Result<Box<dyn SubscriptionSession>, SubscriptionRuntimeError>
fn open_session( &self, subscription_id: &str, resume_cursor: Option<&[u8]>, client_window: u32, control_rx: Receiver<SessionControl>, ) -> Result<Box<dyn SubscriptionSession>, SubscriptionRuntimeError>
Open one session for a validated subscription id. Read more
Auto Trait Implementations§
impl !RefUnwindSafe for CompositeSubscriptionRuntime
impl !UnwindSafe for CompositeSubscriptionRuntime
impl Freeze for CompositeSubscriptionRuntime
impl Send for CompositeSubscriptionRuntime
impl Sync for CompositeSubscriptionRuntime
impl Unpin for CompositeSubscriptionRuntime
impl UnsafeUnpin for CompositeSubscriptionRuntime
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
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more