pub struct TraceSubscribeService { /* private fields */ }Implementations§
Source§impl TraceSubscribeService
impl TraceSubscribeService
pub fn new(router: Arc<TraceRouter>) -> Self
pub fn server(self) -> TraceSubscribeServer<Self>
Trait Implementations§
Source§impl TraceSubscribe for TraceSubscribeService
impl TraceSubscribe for TraceSubscribeService
Source§type SubscribeStream = Pin<Box<dyn Stream<Item = Result<SubscribeResponse, Status>> + Send>>
type SubscribeStream = Pin<Box<dyn Stream<Item = Result<SubscribeResponse, Status>> + Send>>
Server streaming response type for the Subscribe method.
fn subscribe<'life0, 'async_trait>(
&'life0 self,
request: Request<Streaming<SubscribeRequest>>,
) -> Pin<Box<dyn Future<Output = Result<Response<Self::SubscribeStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Auto Trait Implementations§
impl Freeze for TraceSubscribeService
impl RefUnwindSafe for TraceSubscribeService
impl Send for TraceSubscribeService
impl Sync for TraceSubscribeService
impl Unpin for TraceSubscribeService
impl UnsafeUnpin for TraceSubscribeService
impl UnwindSafe for TraceSubscribeService
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> 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> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request