pub struct JormungandrWatchClient {
addr: SocketAddr,
inner_client: WatchClient<Channel>,
rt: Arc<Runtime>,
}
Fields§
§addr: SocketAddr
§inner_client: WatchClient<Channel>
§rt: Arc<Runtime>
Implementations§
source§impl JormungandrWatchClient
impl JormungandrWatchClient
pub fn from_address(address: &str) -> Result<Self, MockClientError>
pub fn new(addr: SocketAddr) -> Self
fn client(&self) -> WatchClient<Channel>
pub fn tip_subscription(&self) -> WatchTipNotifier
pub fn block_subscription(&self, sender: Sender<Result<LibBlock, Status>>)
pub fn sync_multiverse(&self, from: Vec<Hash>) -> Vec<LibBlock>
Trait Implementations§
source§impl Clone for JormungandrWatchClient
impl Clone for JormungandrWatchClient
Auto Trait Implementations§
impl !RefUnwindSafe for JormungandrWatchClient
impl Send for JormungandrWatchClient
impl Sync for JormungandrWatchClient
impl Unpin for JormungandrWatchClient
impl !UnwindSafe for JormungandrWatchClient
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