Struct chain_network::grpc::watch::server::WatchService
source · pub struct WatchService<T> {
inner: T,
}
Fields§
§inner: T
Implementations§
source§impl<T> WatchService<T>
impl<T> WatchService<T>
Trait Implementations§
source§impl<T: Debug> Debug for WatchService<T>
impl<T: Debug> Debug for WatchService<T>
source§impl<T> Watch for WatchService<T>where
T: Watch,
impl<T> Watch for WatchService<T>where T: Watch,
§type BlockSubscriptionStream = OutboundTryStream<<T as Watch>::BlockSubscriptionStream>
type BlockSubscriptionStream = OutboundTryStream<<T as Watch>::BlockSubscriptionStream>
Server streaming response type for the BlockSubscription method.
source§fn block_subscription<'life0, 'async_trait>(
&'life0 self,
request: Request<BlockSubscriptionRequest>
) -> Pin<Box<dyn Future<Output = Result<Response<Self::BlockSubscriptionStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn block_subscription<'life0, 'async_trait>( &'life0 self, request: Request<BlockSubscriptionRequest> ) -> Pin<Box<dyn Future<Output = Result<Response<Self::BlockSubscriptionStream>, Status>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,
get a stream of blocks succesfully processed by the node, this means they
are already validated.
the parent of a block will always be streamed before the block itself.
§type TipSubscriptionStream = OutboundTryStream<<T as Watch>::TipSubscriptionStream>
type TipSubscriptionStream = OutboundTryStream<<T as Watch>::TipSubscriptionStream>
Server streaming response type for the TipSubscription method.
source§fn tip_subscription<'life0, 'async_trait>(
&'life0 self,
request: Request<TipSubscriptionRequest>
) -> Pin<Box<dyn Future<Output = Result<Response<Self::TipSubscriptionStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn tip_subscription<'life0, 'async_trait>( &'life0 self, request: Request<TipSubscriptionRequest> ) -> Pin<Box<dyn Future<Output = Result<Response<Self::TipSubscriptionStream>, Status>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,
get tip updates
§type SyncMultiverseStream = OutboundTryStream<<T as Watch>::SyncMultiverseStream>
type SyncMultiverseStream = OutboundTryStream<<T as Watch>::SyncMultiverseStream>
Server streaming response type for the SyncMultiverse method.
source§fn sync_multiverse<'life0, 'async_trait>(
&'life0 self,
request: Request<SyncMultiverseRequest>
) -> Pin<Box<dyn Future<Output = Result<Response<Self::SyncMultiverseStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn sync_multiverse<'life0, 'async_trait>( &'life0 self, request: Request<SyncMultiverseRequest> ) -> Pin<Box<dyn Future<Output = Result<Response<Self::SyncMultiverseStream>, Status>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,
Fetch all blocks from the blockchain storage that are descendant from
the given checkpoints, The blocks are fetched from all possible branches,
observing parent-to-child order. The order in which any two blocks from
divergent branches are sent is not specified and
should not be relied upon.
Auto Trait Implementations§
impl<T> RefUnwindSafe for WatchService<T>where T: RefUnwindSafe,
impl<T> Send for WatchService<T>where T: Send,
impl<T> Sync for WatchService<T>where T: Sync,
impl<T> Unpin for WatchService<T>where T: Unpin,
impl<T> UnwindSafe for WatchService<T>where T: UnwindSafe,
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
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§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