pub enum MessageServiceResponseWrap {
StreamMessage(StreamMessage),
CatchUpResponse(CatchUpResponse),
RpcResponse(Box<Response<MessageServiceResponse>>),
}Variants§
StreamMessage(StreamMessage)
Streaming messages from background listener tasks
CatchUpResponse(CatchUpResponse)
Catch-up response with batched historical messages from background catch-up tasks
RpcResponse(Box<Response<MessageServiceResponse>>)
RPC response (includes subscription/filter update acknowledgments)
Trait Implementations§
Source§impl Debug for MessageServiceResponseWrap
impl Debug for MessageServiceResponseWrap
Source§impl<'de> Deserialize<'de> for MessageServiceResponseWrap
impl<'de> Deserialize<'de> for MessageServiceResponseWrap
Source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
Auto Trait Implementations§
impl Freeze for MessageServiceResponseWrap
impl RefUnwindSafe for MessageServiceResponseWrap
impl Send for MessageServiceResponseWrap
impl Sync for MessageServiceResponseWrap
impl Unpin for MessageServiceResponseWrap
impl UnwindSafe for MessageServiceResponseWrap
Blanket Implementations§
§impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
§impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
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