Struct holochain::prelude::kitsune_p2p::dependencies::kitsune_p2p_types::dependencies::futures::channel::mpsc::Sender
source · pub struct Sender<T>(/* private fields */);
Expand description
The transmission end of a bounded mpsc channel.
This value is created by the channel
function.
Implementations§
source§impl<T> Sender<T>
impl<T> Sender<T>
sourcepub fn try_send(&mut self, msg: T) -> Result<(), TrySendError<T>>
pub fn try_send(&mut self, msg: T) -> Result<(), TrySendError<T>>
Attempts to send a message on this Sender
, returning the message
if there was an error.
sourcepub fn start_send(&mut self, msg: T) -> Result<(), SendError>
pub fn start_send(&mut self, msg: T) -> Result<(), SendError>
Send a message on the channel.
This function should only be called after
poll_ready
has reported that the channel is
ready to receive a message.
sourcepub fn poll_ready(
&mut self,
cx: &mut Context<'_>
) -> Poll<Result<(), SendError>>
pub fn poll_ready( &mut self, cx: &mut Context<'_> ) -> Poll<Result<(), SendError>>
Polls the channel to determine if there is guaranteed capacity to send at least one item without waiting.
§Return value
This method returns:
Poll::Ready(Ok(_))
if there is sufficient capacity;Poll::Pending
if the channel may not have capacity, in which case the current task is queued to be notified once capacity is available;Poll::Ready(Err(SendError))
if the receiver has been dropped.
sourcepub fn is_closed(&self) -> bool
pub fn is_closed(&self) -> bool
Returns whether this channel is closed without needing a context.
sourcepub fn close_channel(&mut self)
pub fn close_channel(&mut self)
Closes this channel from the sender side, preventing any new messages.
sourcepub fn disconnect(&mut self)
pub fn disconnect(&mut self)
Disconnects this sender from the channel, closing it if there are no more senders left.
sourcepub fn same_receiver(&self, other: &Sender<T>) -> bool
pub fn same_receiver(&self, other: &Sender<T>) -> bool
Returns whether the senders send to the same receiver.
sourcepub fn is_connected_to(&self, receiver: &Receiver<T>) -> bool
pub fn is_connected_to(&self, receiver: &Receiver<T>) -> bool
Returns whether the sender send to this receiver.
sourcepub fn hash_receiver<H>(&self, hasher: &mut H)where
H: Hasher,
pub fn hash_receiver<H>(&self, hasher: &mut H)where
H: Hasher,
Hashes the receiver into the provided hasher
Trait Implementations§
source§impl<E> GhostChannelSender<E> for Sender<E>where
E: GhostEvent,
impl<E> GhostChannelSender<E> for Sender<E>where
E: GhostEvent,
source§fn ghost_actor_channel_send(
&self,
event: E
) -> MustBoxFuture<'static, Result<(), GhostError>> ⓘ
fn ghost_actor_channel_send( &self, event: E ) -> MustBoxFuture<'static, Result<(), GhostError>> ⓘ
source§impl<T> Sink<T> for Sender<T>
impl<T> Sink<T> for Sender<T>
source§fn poll_ready(
self: Pin<&mut Sender<T>>,
cx: &mut Context<'_>
) -> Poll<Result<(), <Sender<T> as Sink<T>>::Error>>
fn poll_ready( self: Pin<&mut Sender<T>>, cx: &mut Context<'_> ) -> Poll<Result<(), <Sender<T> as Sink<T>>::Error>>
Sink
to receive a value. Read moresource§fn start_send(
self: Pin<&mut Sender<T>>,
msg: T
) -> Result<(), <Sender<T> as Sink<T>>::Error>
fn start_send( self: Pin<&mut Sender<T>>, msg: T ) -> Result<(), <Sender<T> as Sink<T>>::Error>
poll_ready
which returned Poll::Ready(Ok(()))
. Read moreAuto Trait Implementations§
impl<T> !RefUnwindSafe for Sender<T>
impl<T> Send for Sender<T>where
T: Send,
impl<T> Sync for Sender<T>where
T: Send,
impl<T> Unpin for Sender<T>
impl<T> !UnwindSafe for Sender<T>
Blanket Implementations§
source§impl<T> ArchivePointee for T
impl<T> ArchivePointee for T
§type ArchivedMetadata = ()
type ArchivedMetadata = ()
source§fn pointer_metadata(
_: &<T as ArchivePointee>::ArchivedMetadata
) -> <T as Pointee>::Metadata
fn pointer_metadata( _: &<T as ArchivePointee>::ArchivedMetadata ) -> <T as Pointee>::Metadata
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
source§impl<F, W, T, D> Deserialize<With<T, W>, D> for F
impl<F, W, T, D> Deserialize<With<T, W>, D> for F
source§impl<T> FutureExt for T
impl<T> FutureExt for T
source§fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
source§fn with_current_context(self) -> WithContext<Self> ⓘ
fn with_current_context(self) -> WithContext<Self> ⓘ
source§impl<S> HolochainP2pEventSender for Swhere
S: GhostChannelSender<HolochainP2pEvent>,
impl<S> HolochainP2pEventSender for Swhere
S: GhostChannelSender<HolochainP2pEvent>,
source§fn put_agent_info_signed(
&self,
dna_hash: HoloHash<Dna>,
peer_data: Vec<AgentInfoSigned>
) -> MustBoxFuture<'static, Result<(), HolochainP2pError>> ⓘ
fn put_agent_info_signed( &self, dna_hash: HoloHash<Dna>, peer_data: Vec<AgentInfoSigned> ) -> MustBoxFuture<'static, Result<(), HolochainP2pError>> ⓘ
source§fn query_agent_info_signed(
&self,
dna_hash: HoloHash<Dna>,
agents: Option<HashSet<Arc<KitsuneAgent>>>,
kitsune_space: Arc<KitsuneSpace>
) -> MustBoxFuture<'static, Result<Vec<AgentInfoSigned>, HolochainP2pError>> ⓘ
fn query_agent_info_signed( &self, dna_hash: HoloHash<Dna>, agents: Option<HashSet<Arc<KitsuneAgent>>>, kitsune_space: Arc<KitsuneSpace> ) -> MustBoxFuture<'static, Result<Vec<AgentInfoSigned>, HolochainP2pError>> ⓘ
agents
parameter is an include filter. This can be thought of as a way to filter a held list of agents against the current state of the store.source§fn query_gossip_agents(
&self,
dna_hash: HoloHash<Dna>,
agents: Option<Vec<HoloHash<Agent>>>,
kitsune_space: Arc<KitsuneSpace>,
since_ms: u64,
until_ms: u64,
arc_set: Arc<DhtArcSet>
) -> MustBoxFuture<'static, Result<Vec<AgentInfoSigned>, HolochainP2pError>> ⓘ
fn query_gossip_agents( &self, dna_hash: HoloHash<Dna>, agents: Option<Vec<HoloHash<Agent>>>, kitsune_space: Arc<KitsuneSpace>, since_ms: u64, until_ms: u64, arc_set: Arc<DhtArcSet> ) -> MustBoxFuture<'static, Result<Vec<AgentInfoSigned>, HolochainP2pError>> ⓘ
source§fn query_agent_info_signed_near_basis(
&self,
dna_hash: HoloHash<Dna>,
kitsune_space: Arc<KitsuneSpace>,
basis_loc: u32,
limit: u32
) -> MustBoxFuture<'static, Result<Vec<AgentInfoSigned>, HolochainP2pError>> ⓘ
fn query_agent_info_signed_near_basis( &self, dna_hash: HoloHash<Dna>, kitsune_space: Arc<KitsuneSpace>, basis_loc: u32, limit: u32 ) -> MustBoxFuture<'static, Result<Vec<AgentInfoSigned>, HolochainP2pError>> ⓘ
source§fn query_peer_density(
&self,
dna_hash: HoloHash<Dna>,
kitsune_space: Arc<KitsuneSpace>,
dht_arc: DhtArc
) -> MustBoxFuture<'static, Result<PeerView, HolochainP2pError>> ⓘ
fn query_peer_density( &self, dna_hash: HoloHash<Dna>, kitsune_space: Arc<KitsuneSpace>, dht_arc: DhtArc ) -> MustBoxFuture<'static, Result<PeerView, HolochainP2pError>> ⓘ
DhtArc
].source§fn call_remote(
&self,
dna_hash: HoloHash<Dna>,
from_agent: HoloHash<Agent>,
signature: Signature,
to_agent: HoloHash<Agent>,
zome_name: ZomeName,
fn_name: FunctionName,
cap_secret: Option<CapSecret>,
payload: ExternIO,
nonce: Nonce256Bits,
expires_at: Timestamp
) -> MustBoxFuture<'static, Result<SerializedBytes, HolochainP2pError>> ⓘ
fn call_remote( &self, dna_hash: HoloHash<Dna>, from_agent: HoloHash<Agent>, signature: Signature, to_agent: HoloHash<Agent>, zome_name: ZomeName, fn_name: FunctionName, cap_secret: Option<CapSecret>, payload: ExternIO, nonce: Nonce256Bits, expires_at: Timestamp ) -> MustBoxFuture<'static, Result<SerializedBytes, HolochainP2pError>> ⓘ
source§fn publish(
&self,
dna_hash: HoloHash<Dna>,
request_validation_receipt: bool,
countersigning_session: bool,
ops: Vec<DhtOp>
) -> MustBoxFuture<'static, Result<(), HolochainP2pError>> ⓘ
fn publish( &self, dna_hash: HoloHash<Dna>, request_validation_receipt: bool, countersigning_session: bool, ops: Vec<DhtOp> ) -> MustBoxFuture<'static, Result<(), HolochainP2pError>> ⓘ
source§fn get(
&self,
dna_hash: HoloHash<Dna>,
to_agent: HoloHash<Agent>,
dht_hash: HoloHash<AnyDht>,
options: GetOptions
) -> MustBoxFuture<'static, Result<WireOps, HolochainP2pError>> ⓘ
fn get( &self, dna_hash: HoloHash<Dna>, to_agent: HoloHash<Agent>, dht_hash: HoloHash<AnyDht>, options: GetOptions ) -> MustBoxFuture<'static, Result<WireOps, HolochainP2pError>> ⓘ
source§fn get_meta(
&self,
dna_hash: HoloHash<Dna>,
to_agent: HoloHash<Agent>,
dht_hash: HoloHash<AnyDht>,
options: GetMetaOptions
) -> MustBoxFuture<'static, Result<MetadataSet, HolochainP2pError>> ⓘ
fn get_meta( &self, dna_hash: HoloHash<Dna>, to_agent: HoloHash<Agent>, dht_hash: HoloHash<AnyDht>, options: GetMetaOptions ) -> MustBoxFuture<'static, Result<MetadataSet, HolochainP2pError>> ⓘ
source§fn get_links(
&self,
dna_hash: HoloHash<Dna>,
to_agent: HoloHash<Agent>,
link_key: WireLinkKey,
options: GetLinksOptions
) -> MustBoxFuture<'static, Result<WireLinkOps, HolochainP2pError>> ⓘ
fn get_links( &self, dna_hash: HoloHash<Dna>, to_agent: HoloHash<Agent>, link_key: WireLinkKey, options: GetLinksOptions ) -> MustBoxFuture<'static, Result<WireLinkOps, HolochainP2pError>> ⓘ
source§fn count_links(
&self,
dna_hash: HoloHash<Dna>,
to_agent: HoloHash<Agent>,
query: WireLinkQuery
) -> MustBoxFuture<'static, Result<CountLinksResponse, HolochainP2pError>> ⓘ
fn count_links( &self, dna_hash: HoloHash<Dna>, to_agent: HoloHash<Agent>, query: WireLinkQuery ) -> MustBoxFuture<'static, Result<CountLinksResponse, HolochainP2pError>> ⓘ
source§fn get_agent_activity(
&self,
dna_hash: HoloHash<Dna>,
to_agent: HoloHash<Agent>,
agent: HoloHash<Agent>,
query: ChainQueryFilter,
options: GetActivityOptions
) -> MustBoxFuture<'static, Result<AgentActivityResponse<HoloHash<Action>>, HolochainP2pError>> ⓘ
fn get_agent_activity( &self, dna_hash: HoloHash<Dna>, to_agent: HoloHash<Agent>, agent: HoloHash<Agent>, query: ChainQueryFilter, options: GetActivityOptions ) -> MustBoxFuture<'static, Result<AgentActivityResponse<HoloHash<Action>>, HolochainP2pError>> ⓘ
source§fn must_get_agent_activity(
&self,
dna_hash: HoloHash<Dna>,
to_agent: HoloHash<Agent>,
author: HoloHash<Agent>,
filter: ChainFilter
) -> MustBoxFuture<'static, Result<MustGetAgentActivityResponse, HolochainP2pError>> ⓘ
fn must_get_agent_activity( &self, dna_hash: HoloHash<Dna>, to_agent: HoloHash<Agent>, author: HoloHash<Agent>, filter: ChainFilter ) -> MustBoxFuture<'static, Result<MustGetAgentActivityResponse, HolochainP2pError>> ⓘ
source§fn validation_receipts_received(
&self,
dna_hash: HoloHash<Dna>,
to_agent: HoloHash<Agent>,
receipts: ValidationReceiptBundle
) -> MustBoxFuture<'static, Result<(), HolochainP2pError>> ⓘ
fn validation_receipts_received( &self, dna_hash: HoloHash<Dna>, to_agent: HoloHash<Agent>, receipts: ValidationReceiptBundle ) -> MustBoxFuture<'static, Result<(), HolochainP2pError>> ⓘ
source§fn query_op_hashes(
&self,
dna_hash: HoloHash<Dna>,
arc_set: DhtArcSet,
window: Range<Timestamp>,
max_ops: usize,
include_limbo: bool
) -> MustBoxFuture<'static, Result<Option<(Vec<HoloHash<DhtOp>>, RangeInclusive<Timestamp>)>, HolochainP2pError>> ⓘ
fn query_op_hashes( &self, dna_hash: HoloHash<Dna>, arc_set: DhtArcSet, window: Range<Timestamp>, max_ops: usize, include_limbo: bool ) -> MustBoxFuture<'static, Result<Option<(Vec<HoloHash<DhtOp>>, RangeInclusive<Timestamp>)>, HolochainP2pError>> ⓘ
source§fn fetch_op_data(
&self,
dna_hash: HoloHash<Dna>,
query: FetchOpDataQuery
) -> MustBoxFuture<'static, Result<Vec<(HoloHash<DhtOp>, DhtOp)>, HolochainP2pError>> ⓘ
fn fetch_op_data( &self, dna_hash: HoloHash<Dna>, query: FetchOpDataQuery ) -> MustBoxFuture<'static, Result<Vec<(HoloHash<DhtOp>, DhtOp)>, HolochainP2pError>> ⓘ
source§fn sign_network_data(
&self,
dna_hash: HoloHash<Dna>,
to_agent: HoloHash<Agent>,
data: Vec<u8>
) -> MustBoxFuture<'static, Result<Signature, HolochainP2pError>> ⓘ
fn sign_network_data( &self, dna_hash: HoloHash<Dna>, to_agent: HoloHash<Agent>, data: Vec<u8> ) -> MustBoxFuture<'static, Result<Signature, HolochainP2pError>> ⓘ
source§fn countersigning_session_negotiation(
&self,
dna_hash: HoloHash<Dna>,
to_agent: HoloHash<Agent>,
message: CountersigningSessionNegotiationMessage
) -> MustBoxFuture<'static, Result<(), HolochainP2pError>> ⓘ
fn countersigning_session_negotiation( &self, dna_hash: HoloHash<Dna>, to_agent: HoloHash<Agent>, message: CountersigningSessionNegotiationMessage ) -> MustBoxFuture<'static, Result<(), HolochainP2pError>> ⓘ
source§impl<S> HolochainP2pSender for Swhere
S: GhostChannelSender<HolochainP2p>,
impl<S> HolochainP2pSender for Swhere
S: GhostChannelSender<HolochainP2p>,
source§fn join(
&self,
dna_hash: HoloHash<Dna>,
agent_pub_key: HoloHash<Agent>,
maybe_agent_info: Option<AgentInfoSigned>,
initial_arc: Option<DhtArc>
) -> MustBoxFuture<'static, Result<(), HolochainP2pError>> ⓘ
fn join( &self, dna_hash: HoloHash<Dna>, agent_pub_key: HoloHash<Agent>, maybe_agent_info: Option<AgentInfoSigned>, initial_arc: Option<DhtArc> ) -> MustBoxFuture<'static, Result<(), HolochainP2pError>> ⓘ
source§fn leave(
&self,
dna_hash: HoloHash<Dna>,
agent_pub_key: HoloHash<Agent>
) -> MustBoxFuture<'static, Result<(), HolochainP2pError>> ⓘ
fn leave( &self, dna_hash: HoloHash<Dna>, agent_pub_key: HoloHash<Agent> ) -> MustBoxFuture<'static, Result<(), HolochainP2pError>> ⓘ
source§fn call_remote(
&self,
dna_hash: HoloHash<Dna>,
from_agent: HoloHash<Agent>,
signature: Signature,
to_agent: HoloHash<Agent>,
zome_name: ZomeName,
fn_name: FunctionName,
cap_secret: Option<CapSecret>,
payload: ExternIO,
nonce: Nonce256Bits,
expires_at: Timestamp
) -> MustBoxFuture<'static, Result<SerializedBytes, HolochainP2pError>> ⓘ
fn call_remote( &self, dna_hash: HoloHash<Dna>, from_agent: HoloHash<Agent>, signature: Signature, to_agent: HoloHash<Agent>, zome_name: ZomeName, fn_name: FunctionName, cap_secret: Option<CapSecret>, payload: ExternIO, nonce: Nonce256Bits, expires_at: Timestamp ) -> MustBoxFuture<'static, Result<SerializedBytes, HolochainP2pError>> ⓘ
source§fn remote_signal(
&self,
dna_hash: HoloHash<Dna>,
from_agent: HoloHash<Agent>,
to_agent_list: Vec<(Signature, HoloHash<Agent>)>,
zome_name: ZomeName,
fn_name: FunctionName,
cap: Option<CapSecret>,
payload: ExternIO,
nonce: Nonce256Bits,
expires_at: Timestamp
) -> MustBoxFuture<'static, Result<(), HolochainP2pError>> ⓘ
fn remote_signal( &self, dna_hash: HoloHash<Dna>, from_agent: HoloHash<Agent>, to_agent_list: Vec<(Signature, HoloHash<Agent>)>, zome_name: ZomeName, fn_name: FunctionName, cap: Option<CapSecret>, payload: ExternIO, nonce: Nonce256Bits, expires_at: Timestamp ) -> MustBoxFuture<'static, Result<(), HolochainP2pError>> ⓘ
source§fn publish(
&self,
dna_hash: HoloHash<Dna>,
request_validation_receipt: bool,
countersigning_session: bool,
basis_hash: HoloHash<AnyLinkable>,
source: HoloHash<Agent>,
op_hash_list: Vec<RoughSized<Arc<KitsuneOpHash>>>,
timeout_ms: Option<u64>,
reflect_ops: Option<Vec<DhtOp>>
) -> MustBoxFuture<'static, Result<(), HolochainP2pError>> ⓘ
fn publish( &self, dna_hash: HoloHash<Dna>, request_validation_receipt: bool, countersigning_session: bool, basis_hash: HoloHash<AnyLinkable>, source: HoloHash<Agent>, op_hash_list: Vec<RoughSized<Arc<KitsuneOpHash>>>, timeout_ms: Option<u64>, reflect_ops: Option<Vec<DhtOp>> ) -> MustBoxFuture<'static, Result<(), HolochainP2pError>> ⓘ
source§fn publish_countersign(
&self,
dna_hash: HoloHash<Dna>,
flag: bool,
basis_hash: HoloHash<AnyLinkable>,
op: DhtOp
) -> MustBoxFuture<'static, Result<(), HolochainP2pError>> ⓘ
fn publish_countersign( &self, dna_hash: HoloHash<Dna>, flag: bool, basis_hash: HoloHash<AnyLinkable>, op: DhtOp ) -> MustBoxFuture<'static, Result<(), HolochainP2pError>> ⓘ
source§fn get(
&self,
dna_hash: HoloHash<Dna>,
dht_hash: HoloHash<AnyDht>,
options: GetOptions
) -> MustBoxFuture<'static, Result<Vec<WireOps>, HolochainP2pError>> ⓘ
fn get( &self, dna_hash: HoloHash<Dna>, dht_hash: HoloHash<AnyDht>, options: GetOptions ) -> MustBoxFuture<'static, Result<Vec<WireOps>, HolochainP2pError>> ⓘ
source§fn get_meta(
&self,
dna_hash: HoloHash<Dna>,
dht_hash: HoloHash<AnyDht>,
options: GetMetaOptions
) -> MustBoxFuture<'static, Result<Vec<MetadataSet>, HolochainP2pError>> ⓘ
fn get_meta( &self, dna_hash: HoloHash<Dna>, dht_hash: HoloHash<AnyDht>, options: GetMetaOptions ) -> MustBoxFuture<'static, Result<Vec<MetadataSet>, HolochainP2pError>> ⓘ
source§fn get_links(
&self,
dna_hash: HoloHash<Dna>,
link_key: WireLinkKey,
options: GetLinksOptions
) -> MustBoxFuture<'static, Result<Vec<WireLinkOps>, HolochainP2pError>> ⓘ
fn get_links( &self, dna_hash: HoloHash<Dna>, link_key: WireLinkKey, options: GetLinksOptions ) -> MustBoxFuture<'static, Result<Vec<WireLinkOps>, HolochainP2pError>> ⓘ
source§fn count_links(
&self,
dna_hash: HoloHash<Dna>,
query: WireLinkQuery
) -> MustBoxFuture<'static, Result<CountLinksResponse, HolochainP2pError>> ⓘ
fn count_links( &self, dna_hash: HoloHash<Dna>, query: WireLinkQuery ) -> MustBoxFuture<'static, Result<CountLinksResponse, HolochainP2pError>> ⓘ
source§fn get_agent_activity(
&self,
dna_hash: HoloHash<Dna>,
agent: HoloHash<Agent>,
query: ChainQueryFilter,
options: GetActivityOptions
) -> MustBoxFuture<'static, Result<Vec<AgentActivityResponse<HoloHash<Action>>>, HolochainP2pError>> ⓘ
fn get_agent_activity( &self, dna_hash: HoloHash<Dna>, agent: HoloHash<Agent>, query: ChainQueryFilter, options: GetActivityOptions ) -> MustBoxFuture<'static, Result<Vec<AgentActivityResponse<HoloHash<Action>>>, HolochainP2pError>> ⓘ
source§fn must_get_agent_activity(
&self,
dna_hash: HoloHash<Dna>,
author: HoloHash<Agent>,
filter: ChainFilter
) -> MustBoxFuture<'static, Result<Vec<MustGetAgentActivityResponse>, HolochainP2pError>> ⓘ
fn must_get_agent_activity( &self, dna_hash: HoloHash<Dna>, author: HoloHash<Agent>, filter: ChainFilter ) -> MustBoxFuture<'static, Result<Vec<MustGetAgentActivityResponse>, HolochainP2pError>> ⓘ
source§fn send_validation_receipts(
&self,
dna_hash: HoloHash<Dna>,
to_agent: HoloHash<Agent>,
receipts: ValidationReceiptBundle
) -> MustBoxFuture<'static, Result<(), HolochainP2pError>> ⓘ
fn send_validation_receipts( &self, dna_hash: HoloHash<Dna>, to_agent: HoloHash<Agent>, receipts: ValidationReceiptBundle ) -> MustBoxFuture<'static, Result<(), HolochainP2pError>> ⓘ
source§fn new_integrated_data(
&self,
dna_hash: HoloHash<Dna>
) -> MustBoxFuture<'static, Result<(), HolochainP2pError>> ⓘ
fn new_integrated_data( &self, dna_hash: HoloHash<Dna> ) -> MustBoxFuture<'static, Result<(), HolochainP2pError>> ⓘ
source§fn countersigning_session_negotiation(
&self,
dna_hash: HoloHash<Dna>,
agents: Vec<HoloHash<Agent>>,
message: CountersigningSessionNegotiationMessage
) -> MustBoxFuture<'static, Result<(), HolochainP2pError>> ⓘ
fn countersigning_session_negotiation( &self, dna_hash: HoloHash<Dna>, agents: Vec<HoloHash<Agent>>, message: CountersigningSessionNegotiationMessage ) -> MustBoxFuture<'static, Result<(), HolochainP2pError>> ⓘ
source§fn dump_network_metrics(
&self,
dna_hash: Option<HoloHash<Dna>>
) -> MustBoxFuture<'static, Result<String, HolochainP2pError>> ⓘ
fn dump_network_metrics( &self, dna_hash: Option<HoloHash<Dna>> ) -> MustBoxFuture<'static, Result<String, HolochainP2pError>> ⓘ
source§fn dump_network_stats(
&self
) -> MustBoxFuture<'static, Result<String, HolochainP2pError>> ⓘ
fn dump_network_stats( &self ) -> MustBoxFuture<'static, Result<String, HolochainP2pError>> ⓘ
source§fn get_diagnostics(
&self,
dna_hash: HoloHash<Dna>
) -> MustBoxFuture<'static, Result<KitsuneDiagnostics, HolochainP2pError>> ⓘ
fn get_diagnostics( &self, dna_hash: HoloHash<Dna> ) -> MustBoxFuture<'static, Result<KitsuneDiagnostics, HolochainP2pError>> ⓘ
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> 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<S> KitsuneP2pEventSender for Swhere
S: GhostChannelSender<KitsuneP2pEvent>,
impl<S> KitsuneP2pEventSender for Swhere
S: GhostChannelSender<KitsuneP2pEvent>,
source§fn put_agent_info_signed(
&self,
input: PutAgentInfoSignedEvt
) -> MustBoxFuture<'static, Result<(), KitsuneP2pError>> ⓘ
fn put_agent_info_signed( &self, input: PutAgentInfoSignedEvt ) -> MustBoxFuture<'static, Result<(), KitsuneP2pError>> ⓘ
source§fn query_agents(
&self,
input: QueryAgentsEvt
) -> MustBoxFuture<'static, Result<Vec<AgentInfoSigned>, KitsuneP2pError>> ⓘ
fn query_agents( &self, input: QueryAgentsEvt ) -> MustBoxFuture<'static, Result<Vec<AgentInfoSigned>, KitsuneP2pError>> ⓘ
source§fn query_peer_density(
&self,
space: Arc<KitsuneSpace>,
dht_arc: DhtArc
) -> MustBoxFuture<'static, Result<PeerView, KitsuneP2pError>> ⓘ
fn query_peer_density( &self, space: Arc<KitsuneSpace>, dht_arc: DhtArc ) -> MustBoxFuture<'static, Result<PeerView, KitsuneP2pError>> ⓘ
DhtArc
].source§fn call(
&self,
space: Arc<KitsuneSpace>,
to_agent: Arc<KitsuneAgent>,
payload: Vec<u8>
) -> MustBoxFuture<'static, Result<Vec<u8>, KitsuneP2pError>> ⓘ
fn call( &self, space: Arc<KitsuneSpace>, to_agent: Arc<KitsuneAgent>, payload: Vec<u8> ) -> MustBoxFuture<'static, Result<Vec<u8>, KitsuneP2pError>> ⓘ
source§fn notify(
&self,
space: Arc<KitsuneSpace>,
to_agent: Arc<KitsuneAgent>,
payload: Vec<u8>
) -> MustBoxFuture<'static, Result<(), KitsuneP2pError>> ⓘ
fn notify( &self, space: Arc<KitsuneSpace>, to_agent: Arc<KitsuneAgent>, payload: Vec<u8> ) -> MustBoxFuture<'static, Result<(), KitsuneP2pError>> ⓘ
source§fn receive_ops(
&self,
space: Arc<KitsuneSpace>,
ops: Vec<Arc<KitsuneOpData>>,
context: Option<FetchContext>
) -> MustBoxFuture<'static, Result<(), KitsuneP2pError>> ⓘ
fn receive_ops( &self, space: Arc<KitsuneSpace>, ops: Vec<Arc<KitsuneOpData>>, context: Option<FetchContext> ) -> MustBoxFuture<'static, Result<(), KitsuneP2pError>> ⓘ
source§fn query_op_hashes(
&self,
input: QueryOpHashesEvt
) -> MustBoxFuture<'static, Result<Option<(Vec<Arc<KitsuneOpHash>>, RangeInclusive<Timestamp>)>, KitsuneP2pError>> ⓘ
fn query_op_hashes( &self, input: QueryOpHashesEvt ) -> MustBoxFuture<'static, Result<Option<(Vec<Arc<KitsuneOpHash>>, RangeInclusive<Timestamp>)>, KitsuneP2pError>> ⓘ
source§fn fetch_op_data(
&self,
input: FetchOpDataEvt
) -> MustBoxFuture<'static, Result<Vec<(Arc<KitsuneOpHash>, Arc<KitsuneOpData>)>, KitsuneP2pError>> ⓘ
fn fetch_op_data( &self, input: FetchOpDataEvt ) -> MustBoxFuture<'static, Result<Vec<(Arc<KitsuneOpHash>, Arc<KitsuneOpData>)>, KitsuneP2pError>> ⓘ
source§fn sign_network_data(
&self,
input: SignNetworkDataEvt
) -> MustBoxFuture<'static, Result<KitsuneSignature, KitsuneP2pError>> ⓘ
fn sign_network_data( &self, input: SignNetworkDataEvt ) -> MustBoxFuture<'static, Result<KitsuneSignature, KitsuneP2pError>> ⓘ
source§impl<S> KitsuneP2pSender for Swhere
S: GhostChannelSender<KitsuneP2p>,
impl<S> KitsuneP2pSender for Swhere
S: GhostChannelSender<KitsuneP2p>,
source§fn list_transport_bindings(
&self
) -> MustBoxFuture<'static, Result<Vec<Url2>, KitsuneP2pError>> ⓘ
fn list_transport_bindings( &self ) -> MustBoxFuture<'static, Result<Vec<Url2>, KitsuneP2pError>> ⓘ
source§fn join(
&self,
space: Arc<KitsuneSpace>,
agent: Arc<KitsuneAgent>,
maybe_agent_info: Option<AgentInfoSigned>,
initial_arc: Option<DhtArc>
) -> MustBoxFuture<'static, Result<(), KitsuneP2pError>> ⓘ
fn join( &self, space: Arc<KitsuneSpace>, agent: Arc<KitsuneAgent>, maybe_agent_info: Option<AgentInfoSigned>, initial_arc: Option<DhtArc> ) -> MustBoxFuture<'static, Result<(), KitsuneP2pError>> ⓘ
source§fn leave(
&self,
space: Arc<KitsuneSpace>,
agent: Arc<KitsuneAgent>
) -> MustBoxFuture<'static, Result<(), KitsuneP2pError>> ⓘ
fn leave( &self, space: Arc<KitsuneSpace>, agent: Arc<KitsuneAgent> ) -> MustBoxFuture<'static, Result<(), KitsuneP2pError>> ⓘ
source§fn rpc_single(
&self,
space: Arc<KitsuneSpace>,
to_agent: Arc<KitsuneAgent>,
payload: Vec<u8>,
timeout_ms: Option<u64>
) -> MustBoxFuture<'static, Result<Vec<u8>, KitsuneP2pError>> ⓘ
fn rpc_single( &self, space: Arc<KitsuneSpace>, to_agent: Arc<KitsuneAgent>, payload: Vec<u8>, timeout_ms: Option<u64> ) -> MustBoxFuture<'static, Result<Vec<u8>, KitsuneP2pError>> ⓘ
source§fn rpc_multi(
&self,
input: RpcMulti
) -> MustBoxFuture<'static, Result<Vec<RpcMultiResponse>, KitsuneP2pError>> ⓘ
fn rpc_multi( &self, input: RpcMulti ) -> MustBoxFuture<'static, Result<Vec<RpcMultiResponse>, KitsuneP2pError>> ⓘ
source§fn broadcast(
&self,
space: Arc<KitsuneSpace>,
basis: Arc<KitsuneBasis>,
timeout: KitsuneTimeout,
data: BroadcastData
) -> MustBoxFuture<'static, Result<(), KitsuneP2pError>> ⓘ
fn broadcast( &self, space: Arc<KitsuneSpace>, basis: Arc<KitsuneBasis>, timeout: KitsuneTimeout, data: BroadcastData ) -> MustBoxFuture<'static, Result<(), KitsuneP2pError>> ⓘ
source§fn targeted_broadcast(
&self,
space: Arc<KitsuneSpace>,
agents: Vec<Arc<KitsuneAgent>>,
timeout: KitsuneTimeout,
payload: Vec<u8>,
drop_at_limit: bool
) -> MustBoxFuture<'static, Result<(), KitsuneP2pError>> ⓘ
fn targeted_broadcast( &self, space: Arc<KitsuneSpace>, agents: Vec<Arc<KitsuneAgent>>, timeout: KitsuneTimeout, payload: Vec<u8>, drop_at_limit: bool ) -> MustBoxFuture<'static, Result<(), KitsuneP2pError>> ⓘ
source§fn new_integrated_data(
&self,
space: Arc<KitsuneSpace>
) -> MustBoxFuture<'static, Result<(), KitsuneP2pError>> ⓘ
fn new_integrated_data( &self, space: Arc<KitsuneSpace> ) -> MustBoxFuture<'static, Result<(), KitsuneP2pError>> ⓘ
source§fn dump_network_metrics(
&self,
space: Option<Arc<KitsuneSpace>>
) -> MustBoxFuture<'static, Result<Value, KitsuneP2pError>> ⓘ
fn dump_network_metrics( &self, space: Option<Arc<KitsuneSpace>> ) -> MustBoxFuture<'static, Result<Value, KitsuneP2pError>> ⓘ
source§fn dump_network_stats(
&self
) -> MustBoxFuture<'static, Result<Value, KitsuneP2pError>> ⓘ
fn dump_network_stats( &self ) -> MustBoxFuture<'static, Result<Value, KitsuneP2pError>> ⓘ
source§fn get_diagnostics(
&self,
space: Arc<KitsuneSpace>
) -> MustBoxFuture<'static, Result<KitsuneDiagnostics, KitsuneP2pError>> ⓘ
fn get_diagnostics( &self, space: Arc<KitsuneSpace> ) -> MustBoxFuture<'static, Result<KitsuneDiagnostics, KitsuneP2pError>> ⓘ
source§impl<T> LayoutRaw for T
impl<T> LayoutRaw for T
source§fn layout_raw(_: <T as Pointee>::Metadata) -> Result<Layout, LayoutError>
fn layout_raw(_: <T as Pointee>::Metadata) -> Result<Layout, LayoutError>
source§impl<T> Pointable for T
impl<T> Pointable for T
source§impl<T, Item> SinkExt<Item> for T
impl<T, Item> SinkExt<Item> for T
source§fn with<U, Fut, F, E>(self, f: F) -> With<Self, Item, U, Fut, F>
fn with<U, Fut, F, E>(self, f: F) -> With<Self, Item, U, Fut, F>
source§fn with_flat_map<U, St, F>(self, f: F) -> WithFlatMap<Self, Item, U, St, F>
fn with_flat_map<U, St, F>(self, f: F) -> WithFlatMap<Self, Item, U, St, F>
source§fn sink_map_err<E, F>(self, f: F) -> SinkMapErr<Self, F>
fn sink_map_err<E, F>(self, f: F) -> SinkMapErr<Self, F>
source§fn sink_err_into<E>(self) -> SinkErrInto<Self, Item, E>
fn sink_err_into<E>(self) -> SinkErrInto<Self, Item, E>
Into
trait. Read moresource§fn buffer(self, capacity: usize) -> Buffer<Self, Item>where
Self: Sized,
fn buffer(self, capacity: usize) -> Buffer<Self, Item>where
Self: Sized,
source§fn flush(&mut self) -> Flush<'_, Self, Item> ⓘwhere
Self: Unpin,
fn flush(&mut self) -> Flush<'_, Self, Item> ⓘwhere
Self: Unpin,
source§fn send(&mut self, item: Item) -> Send<'_, Self, Item> ⓘwhere
Self: Unpin,
fn send(&mut self, item: Item) -> Send<'_, Self, Item> ⓘwhere
Self: Unpin,
source§fn feed(&mut self, item: Item) -> Feed<'_, Self, Item> ⓘwhere
Self: Unpin,
fn feed(&mut self, item: Item) -> Feed<'_, Self, Item> ⓘwhere
Self: Unpin,
source§fn send_all<'a, St>(&'a mut self, stream: &'a mut St) -> SendAll<'a, Self, St> ⓘ
fn send_all<'a, St>(&'a mut self, stream: &'a mut St) -> SendAll<'a, Self, St> ⓘ
source§fn right_sink<Si1>(self) -> Either<Si1, Self> ⓘ
fn right_sink<Si1>(self) -> Either<Si1, Self> ⓘ
source§fn poll_ready_unpin(
&mut self,
cx: &mut Context<'_>
) -> Poll<Result<(), Self::Error>>where
Self: Unpin,
fn poll_ready_unpin(
&mut self,
cx: &mut Context<'_>
) -> Poll<Result<(), Self::Error>>where
Self: Unpin,
Sink::poll_ready
on Unpin
sink types.source§fn start_send_unpin(&mut self, item: Item) -> Result<(), Self::Error>where
Self: Unpin,
fn start_send_unpin(&mut self, item: Item) -> Result<(), Self::Error>where
Self: Unpin,
Sink::start_send
on Unpin
sink types.source§impl<Item, S> SinkRateLimitExt<Item, S> for Swhere
S: Sink<Item>,
impl<Item, S> SinkRateLimitExt<Item, S> for Swhere
S: Sink<Item>,
source§fn ratelimit_sink<D, C>(
self,
limiter: &RateLimiter<NotKeyed, D, C>
) -> RatelimitedSink<'_, Item, S, D, C>where
D: DirectStateStore,
C: ReasonablyRealtime,
fn ratelimit_sink<D, C>(
self,
limiter: &RateLimiter<NotKeyed, D, C>
) -> RatelimitedSink<'_, Item, S, D, C>where
D: DirectStateStore,
C: ReasonablyRealtime,
source§fn ratelimit_sink_with_jitter<D, C>(
self,
limiter: &RateLimiter<NotKeyed, D, C>,
jitter: Jitter
) -> RatelimitedSink<'_, Item, S, D, C>where
D: DirectStateStore,
C: ReasonablyRealtime,
fn ratelimit_sink_with_jitter<D, C>(
self,
limiter: &RateLimiter<NotKeyed, D, C>,
jitter: Jitter
) -> RatelimitedSink<'_, Item, S, D, C>where
D: DirectStateStore,
C: ReasonablyRealtime,
source§impl<SS, SP> SupersetOf<SS> for SPwhere
SS: SubsetOf<SP>,
impl<SS, SP> SupersetOf<SS> for SPwhere
SS: SubsetOf<SP>,
source§fn to_subset(&self) -> Option<SS>
fn to_subset(&self) -> Option<SS>
self
from the equivalent element of its
superset. Read moresource§fn is_in_subset(&self) -> bool
fn is_in_subset(&self) -> bool
self
is actually part of its subset T
(and can be converted to it).source§fn to_subset_unchecked(&self) -> SS
fn to_subset_unchecked(&self) -> SS
self.to_subset
but without any property checks. Always succeeds.source§fn from_subset(element: &SS) -> SP
fn from_subset(element: &SS) -> SP
self
to the equivalent element of its superset.