pub struct RpcInnerBuilder { /* private fields */ }Expand description
Builder for RpcInner.
Implementations§
Source§impl RpcInnerBuilder
impl RpcInnerBuilder
pub fn id(self, value: State<IdBytes>) -> Self
pub fn kbuckets(self, value: KBucketsTable<Node>) -> Self
pub fn io(self, value: IoHandler) -> Self
pub fn bootstrap_job(self, value: PeriodicJob) -> Self
pub fn ping_job(self, value: PeriodicJob) -> Self
Sourcepub fn queries(self, value: QueryPool) -> Self
pub fn queries(self, value: QueryPool) -> Self
The currently active (i.e. in-progress) queries.
Sourcepub fn queued_events(self, value: VecDeque<RpcEvent>) -> Self
pub fn queued_events(self, value: VecDeque<RpcEvent>) -> Self
Queued events to return when being polled.
pub fn bootstrap_nodes(self, value: Vec<SocketAddr>) -> Self
pub fn bootstrapped(self, value: bool) -> Self
pub fn down_hints_in_progress(self, value: Vec<(u16, IdBytes, Instant)>) -> Self
pub fn pending_requests( self, value: BTreeMap<Tid, Sender<Arc<InResponse>>>, ) -> Self
pub fn stream_waker(self, value: Option<Waker>) -> Self
pub fn pending_queries( self, value: BTreeMap<QueryId, Sender<Arc<QueryResult>>>, ) -> Self
pub fn pending_bootstrap(self, value: Option<Sender<Arc<Bootstrapped>>>) -> Self
pub fn pending_query_streams( self, value: BTreeMap<QueryId, Sender<Arc<InResponse>>>, ) -> Self
Trait Implementations§
Auto Trait Implementations§
impl !Freeze for RpcInnerBuilder
impl !RefUnwindSafe for RpcInnerBuilder
impl !UnwindSafe for RpcInnerBuilder
impl Send for RpcInnerBuilder
impl Sync for RpcInnerBuilder
impl Unpin for RpcInnerBuilder
impl UnsafeUnpin for RpcInnerBuilder
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