Struct holochain::prelude::dependencies::kitsune_p2p_types::dependencies::futures::channel::mpsc::Sender
pub struct Sender<T>(_);
Expand description
The transmission end of a bounded mpsc channel.
This value is created by the channel
function.
Implementations
impl<T> Sender<T>
impl<T> Sender<T>
pub 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.
pub 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.
pub 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.
pub fn close_channel(&mut self)
pub fn close_channel(&mut self)
Closes this channel from the sender side, preventing any new messages.
pub fn disconnect(&mut self)
pub fn disconnect(&mut self)
Disconnects this sender from the channel, closing it if there are no more senders left.
pub 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.
pub 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.
pub 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
sourceimpl<E> GhostChannelSender<E> for Sender<E>where
E: GhostEvent,
impl<E> GhostChannelSender<E> for Sender<E>where
E: GhostEvent,
sourcefn ghost_actor_channel_send(
&self,
event: E
) -> MustBoxFuture<'static, Result<(), GhostError>> ⓘ
fn ghost_actor_channel_send(
&self,
event: E
) -> MustBoxFuture<'static, Result<(), GhostError>> ⓘ
impl<T> Sink<T> for Sender<T>
impl<T> Sink<T> for Sender<T>
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 morefn 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
impl<T> Any for Twhere
T: Any + ?Sized,
impl<T> Any for Twhere
T: Any + ?Sized,
fn type_id_compat(&self) -> TypeId
fn type_id_compat(&self) -> TypeId
impl<T> ArchivePointee for T
impl<T> ArchivePointee for T
type ArchivedMetadata = ()
type ArchivedMetadata = ()
fn pointer_metadata(
_: &<T as ArchivePointee>::ArchivedMetadata
) -> <T as Pointee>::Metadata
fn pointer_metadata(
_: &<T as ArchivePointee>::ArchivedMetadata
) -> <T as Pointee>::Metadata
sourceimpl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
impl<F, W, T, D> Deserialize<With<T, W>, D> for Fwhere
W: DeserializeWith<F, T, D>,
D: Fallible + ?Sized,
F: ?Sized,
impl<F, W, T, D> Deserialize<With<T, W>, D> for Fwhere
W: DeserializeWith<F, T, D>,
D: Fallible + ?Sized,
F: ?Sized,
fn deserialize(
&self,
deserializer: &mut D
) -> Result<With<T, W>, <D as Fallible>::Error>
fn deserialize(
&self,
deserializer: &mut D
) -> Result<With<T, W>, <D as Fallible>::Error>
impl<T> FutureExt for T
impl<T> FutureExt for T
fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
fn with_current_context(self) -> WithContext<Self> ⓘ
fn with_current_context(self) -> WithContext<Self> ⓘ
sourceimpl<S> HolochainP2pEventSender for Swhere
S: GhostChannelSender<HolochainP2pEvent>,
impl<S> HolochainP2pEventSender for Swhere
S: GhostChannelSender<HolochainP2pEvent>,
sourcefn put_agent_info_signed(
&self,
dna_hash: HoloHash<Dna>,
peer_data: Vec<AgentInfoSigned, Global>
) -> MustBoxFuture<'static, Result<(), HolochainP2pError>> ⓘ
fn put_agent_info_signed(
&self,
dna_hash: HoloHash<Dna>,
peer_data: Vec<AgentInfoSigned, Global>
) -> MustBoxFuture<'static, Result<(), HolochainP2pError>> ⓘ
sourcefn query_agent_info_signed(
&self,
dna_hash: HoloHash<Dna>,
agents: Option<HashSet<Arc<KitsuneAgent>, RandomState>>,
kitsune_space: Arc<KitsuneSpace>
) -> MustBoxFuture<'static, Result<Vec<AgentInfoSigned, Global>, HolochainP2pError>> ⓘ
fn query_agent_info_signed(
&self,
dna_hash: HoloHash<Dna>,
agents: Option<HashSet<Arc<KitsuneAgent>, RandomState>>,
kitsune_space: Arc<KitsuneSpace>
) -> MustBoxFuture<'static, Result<Vec<AgentInfoSigned, Global>, HolochainP2pError>> ⓘ
sourcefn query_gossip_agents(
&self,
dna_hash: HoloHash<Dna>,
agents: Option<Vec<HoloHash<Agent>, Global>>,
kitsune_space: Arc<KitsuneSpace>,
since_ms: u64,
until_ms: u64,
arc_set: Arc<DhtArcSet>
) -> MustBoxFuture<'static, Result<Vec<AgentInfoSigned, Global>, HolochainP2pError>> ⓘ
fn query_gossip_agents(
&self,
dna_hash: HoloHash<Dna>,
agents: Option<Vec<HoloHash<Agent>, Global>>,
kitsune_space: Arc<KitsuneSpace>,
since_ms: u64,
until_ms: u64,
arc_set: Arc<DhtArcSet>
) -> MustBoxFuture<'static, Result<Vec<AgentInfoSigned, Global>, HolochainP2pError>> ⓘ
sourcefn 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, Global>, 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, Global>, HolochainP2pError>> ⓘ
sourcefn 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
].sourcefn call_remote(
&self,
dna_hash: HoloHash<Dna>,
to_agent: HoloHash<Agent>,
from_agent: HoloHash<Agent>,
zome_name: ZomeName,
fn_name: FunctionName,
cap_secret: Option<CapSecret>,
payload: ExternIO
) -> MustBoxFuture<'static, Result<SerializedBytes, HolochainP2pError>> ⓘ
fn call_remote(
&self,
dna_hash: HoloHash<Dna>,
to_agent: HoloHash<Agent>,
from_agent: HoloHash<Agent>,
zome_name: ZomeName,
fn_name: FunctionName,
cap_secret: Option<CapSecret>,
payload: ExternIO
) -> MustBoxFuture<'static, Result<SerializedBytes, HolochainP2pError>> ⓘ
sourcefn publish(
&self,
dna_hash: HoloHash<Dna>,
request_validation_receipt: bool,
countersigning_session: bool,
ops: Vec<DhtOp, Global>
) -> MustBoxFuture<'static, Result<(), HolochainP2pError>> ⓘ
fn publish(
&self,
dna_hash: HoloHash<Dna>,
request_validation_receipt: bool,
countersigning_session: bool,
ops: Vec<DhtOp, Global>
) -> MustBoxFuture<'static, Result<(), HolochainP2pError>> ⓘ
sourcefn 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>> ⓘ
sourcefn 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>> ⓘ
sourcefn 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>> ⓘ
sourcefn 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>> ⓘ
sourcefn must_get_agent_activity(
&self,
dna_hash: HoloHash<Dna>,
to_agent: HoloHash<Agent>,
author: HoloHash<Agent>,
filter: ChainFilter<HoloHash<Action>>
) -> MustBoxFuture<'static, Result<MustGetAgentActivityResponse, HolochainP2pError>> ⓘ
fn must_get_agent_activity(
&self,
dna_hash: HoloHash<Dna>,
to_agent: HoloHash<Agent>,
author: HoloHash<Agent>,
filter: ChainFilter<HoloHash<Action>>
) -> MustBoxFuture<'static, Result<MustGetAgentActivityResponse, HolochainP2pError>> ⓘ
sourcefn validation_receipt_received(
&self,
dna_hash: HoloHash<Dna>,
to_agent: HoloHash<Agent>,
receipt: SerializedBytes
) -> MustBoxFuture<'static, Result<(), HolochainP2pError>> ⓘ
fn validation_receipt_received(
&self,
dna_hash: HoloHash<Dna>,
to_agent: HoloHash<Agent>,
receipt: SerializedBytes
) -> MustBoxFuture<'static, Result<(), HolochainP2pError>> ⓘ
sourcefn 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>, Global>, 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>, Global>, RangeInclusive<Timestamp>)>, HolochainP2pError>> ⓘ
sourcefn fetch_op_data(
&self,
dna_hash: HoloHash<Dna>,
query: FetchOpDataQuery
) -> MustBoxFuture<'static, Result<Vec<(HoloHash<DhtOp>, DhtOp), Global>, HolochainP2pError>> ⓘ
fn fetch_op_data(
&self,
dna_hash: HoloHash<Dna>,
query: FetchOpDataQuery
) -> MustBoxFuture<'static, Result<Vec<(HoloHash<DhtOp>, DhtOp), Global>, HolochainP2pError>> ⓘ
sourcefn sign_network_data(
&self,
dna_hash: HoloHash<Dna>,
to_agent: HoloHash<Agent>,
data: Vec<u8, Global>
) -> MustBoxFuture<'static, Result<Signature, HolochainP2pError>> ⓘ
fn sign_network_data(
&self,
dna_hash: HoloHash<Dna>,
to_agent: HoloHash<Agent>,
data: Vec<u8, Global>
) -> MustBoxFuture<'static, Result<Signature, HolochainP2pError>> ⓘ
sourcefn 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>> ⓘ
sourceimpl<S> HolochainP2pSender for Swhere
S: GhostChannelSender<HolochainP2p>,
impl<S> HolochainP2pSender for Swhere
S: GhostChannelSender<HolochainP2p>,
sourcefn join(
&self,
dna_hash: HoloHash<Dna>,
agent_pub_key: HoloHash<Agent>,
initial_arc: Option<DhtArc>
) -> MustBoxFuture<'static, Result<(), HolochainP2pError>> ⓘ
fn join(
&self,
dna_hash: HoloHash<Dna>,
agent_pub_key: HoloHash<Agent>,
initial_arc: Option<DhtArc>
) -> MustBoxFuture<'static, Result<(), HolochainP2pError>> ⓘ
sourcefn 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>> ⓘ
sourcefn call_remote(
&self,
dna_hash: HoloHash<Dna>,
from_agent: HoloHash<Agent>,
to_agent: HoloHash<Agent>,
zome_name: ZomeName,
fn_name: FunctionName,
cap_secret: Option<CapSecret>,
payload: ExternIO
) -> MustBoxFuture<'static, Result<SerializedBytes, HolochainP2pError>> ⓘ
fn call_remote(
&self,
dna_hash: HoloHash<Dna>,
from_agent: HoloHash<Agent>,
to_agent: HoloHash<Agent>,
zome_name: ZomeName,
fn_name: FunctionName,
cap_secret: Option<CapSecret>,
payload: ExternIO
) -> MustBoxFuture<'static, Result<SerializedBytes, HolochainP2pError>> ⓘ
sourcefn remote_signal(
&self,
dna_hash: HoloHash<Dna>,
from_agent: HoloHash<Agent>,
to_agent_list: Vec<HoloHash<Agent>, Global>,
zome_name: ZomeName,
fn_name: FunctionName,
cap: Option<CapSecret>,
payload: ExternIO
) -> MustBoxFuture<'static, Result<(), HolochainP2pError>> ⓘ
fn remote_signal(
&self,
dna_hash: HoloHash<Dna>,
from_agent: HoloHash<Agent>,
to_agent_list: Vec<HoloHash<Agent>, Global>,
zome_name: ZomeName,
fn_name: FunctionName,
cap: Option<CapSecret>,
payload: ExternIO
) -> MustBoxFuture<'static, Result<(), HolochainP2pError>> ⓘ
sourcefn publish(
&self,
dna_hash: HoloHash<Dna>,
request_validation_receipt: bool,
countersigning_session: bool,
basis_hash: HoloHash<AnyLinkable>,
ops: Vec<DhtOp, Global>,
timeout_ms: Option<u64>
) -> MustBoxFuture<'static, Result<usize, HolochainP2pError>> ⓘ
fn publish(
&self,
dna_hash: HoloHash<Dna>,
request_validation_receipt: bool,
countersigning_session: bool,
basis_hash: HoloHash<AnyLinkable>,
ops: Vec<DhtOp, Global>,
timeout_ms: Option<u64>
) -> MustBoxFuture<'static, Result<usize, HolochainP2pError>> ⓘ
sourcefn get(
&self,
dna_hash: HoloHash<Dna>,
dht_hash: HoloHash<AnyDht>,
options: GetOptions
) -> MustBoxFuture<'static, Result<Vec<WireOps, Global>, HolochainP2pError>> ⓘ
fn get(
&self,
dna_hash: HoloHash<Dna>,
dht_hash: HoloHash<AnyDht>,
options: GetOptions
) -> MustBoxFuture<'static, Result<Vec<WireOps, Global>, HolochainP2pError>> ⓘ
sourcefn get_meta(
&self,
dna_hash: HoloHash<Dna>,
dht_hash: HoloHash<AnyDht>,
options: GetMetaOptions
) -> MustBoxFuture<'static, Result<Vec<MetadataSet, Global>, HolochainP2pError>> ⓘ
fn get_meta(
&self,
dna_hash: HoloHash<Dna>,
dht_hash: HoloHash<AnyDht>,
options: GetMetaOptions
) -> MustBoxFuture<'static, Result<Vec<MetadataSet, Global>, HolochainP2pError>> ⓘ
sourcefn get_links(
&self,
dna_hash: HoloHash<Dna>,
link_key: WireLinkKey,
options: GetLinksOptions
) -> MustBoxFuture<'static, Result<Vec<WireLinkOps, Global>, HolochainP2pError>> ⓘ
fn get_links(
&self,
dna_hash: HoloHash<Dna>,
link_key: WireLinkKey,
options: GetLinksOptions
) -> MustBoxFuture<'static, Result<Vec<WireLinkOps, Global>, HolochainP2pError>> ⓘ
sourcefn get_agent_activity(
&self,
dna_hash: HoloHash<Dna>,
agent: HoloHash<Agent>,
query: ChainQueryFilter,
options: GetActivityOptions
) -> MustBoxFuture<'static, Result<Vec<AgentActivityResponse<HoloHash<Action>>, Global>, HolochainP2pError>> ⓘ
fn get_agent_activity(
&self,
dna_hash: HoloHash<Dna>,
agent: HoloHash<Agent>,
query: ChainQueryFilter,
options: GetActivityOptions
) -> MustBoxFuture<'static, Result<Vec<AgentActivityResponse<HoloHash<Action>>, Global>, HolochainP2pError>> ⓘ
sourcefn must_get_agent_activity(
&self,
dna_hash: HoloHash<Dna>,
author: HoloHash<Agent>,
filter: ChainFilter<HoloHash<Action>>
) -> MustBoxFuture<'static, Result<Vec<MustGetAgentActivityResponse, Global>, HolochainP2pError>> ⓘ
fn must_get_agent_activity(
&self,
dna_hash: HoloHash<Dna>,
author: HoloHash<Agent>,
filter: ChainFilter<HoloHash<Action>>
) -> MustBoxFuture<'static, Result<Vec<MustGetAgentActivityResponse, Global>, HolochainP2pError>> ⓘ
sourcefn send_validation_receipt(
&self,
dna_hash: HoloHash<Dna>,
to_agent: HoloHash<Agent>,
receipt: SerializedBytes
) -> MustBoxFuture<'static, Result<(), HolochainP2pError>> ⓘ
fn send_validation_receipt(
&self,
dna_hash: HoloHash<Dna>,
to_agent: HoloHash<Agent>,
receipt: SerializedBytes
) -> MustBoxFuture<'static, Result<(), HolochainP2pError>> ⓘ
sourcefn 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>> ⓘ
sourcefn countersigning_session_negotiation(
&self,
dna_hash: HoloHash<Dna>,
agents: Vec<HoloHash<Agent>, Global>,
message: CountersigningSessionNegotiationMessage
) -> MustBoxFuture<'static, Result<(), HolochainP2pError>> ⓘ
fn countersigning_session_negotiation(
&self,
dna_hash: HoloHash<Dna>,
agents: Vec<HoloHash<Agent>, Global>,
message: CountersigningSessionNegotiationMessage
) -> MustBoxFuture<'static, Result<(), HolochainP2pError>> ⓘ
sourcefn 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>> ⓘ
sourcefn get_diagnostics(
&self,
dna_hash: HoloHash<Dna>
) -> MustBoxFuture<'static, Result<GossipDiagnostics, HolochainP2pError>> ⓘ
fn get_diagnostics(
&self,
dna_hash: HoloHash<Dna>
) -> MustBoxFuture<'static, Result<GossipDiagnostics, HolochainP2pError>> ⓘ
sourceimpl<T> Instrument for T
impl<T> Instrument for T
sourcefn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
sourcefn in_current_span(self) -> Instrumented<Self> ⓘ
fn in_current_span(self) -> Instrumented<Self> ⓘ
sourceimpl<T> Instrument for T
impl<T> Instrument for T
sourcefn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
sourcefn in_current_span(self) -> Instrumented<Self> ⓘ
fn in_current_span(self) -> Instrumented<Self> ⓘ
sourceimpl<S> KitsuneP2pEventSender for Swhere
S: GhostChannelSender<KitsuneP2pEvent>,
impl<S> KitsuneP2pEventSender for Swhere
S: GhostChannelSender<KitsuneP2pEvent>,
sourcefn put_agent_info_signed(
&self,
input: PutAgentInfoSignedEvt
) -> MustBoxFuture<'static, Result<(), KitsuneP2pError>> ⓘ
fn put_agent_info_signed(
&self,
input: PutAgentInfoSignedEvt
) -> MustBoxFuture<'static, Result<(), KitsuneP2pError>> ⓘ
sourcefn query_agents(
&self,
input: QueryAgentsEvt
) -> MustBoxFuture<'static, Result<Vec<AgentInfoSigned, Global>, KitsuneP2pError>> ⓘ
fn query_agents(
&self,
input: QueryAgentsEvt
) -> MustBoxFuture<'static, Result<Vec<AgentInfoSigned, Global>, KitsuneP2pError>> ⓘ
sourcefn 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
].sourcefn call(
&self,
space: Arc<KitsuneSpace>,
to_agent: Arc<KitsuneAgent>,
payload: Vec<u8, Global>
) -> MustBoxFuture<'static, Result<Vec<u8, Global>, KitsuneP2pError>> ⓘ
fn call(
&self,
space: Arc<KitsuneSpace>,
to_agent: Arc<KitsuneAgent>,
payload: Vec<u8, Global>
) -> MustBoxFuture<'static, Result<Vec<u8, Global>, KitsuneP2pError>> ⓘ
sourcefn notify(
&self,
space: Arc<KitsuneSpace>,
to_agent: Arc<KitsuneAgent>,
payload: Vec<u8, Global>
) -> MustBoxFuture<'static, Result<(), KitsuneP2pError>> ⓘ
fn notify(
&self,
space: Arc<KitsuneSpace>,
to_agent: Arc<KitsuneAgent>,
payload: Vec<u8, Global>
) -> MustBoxFuture<'static, Result<(), KitsuneP2pError>> ⓘ
sourcefn gossip(
&self,
space: Arc<KitsuneSpace>,
ops: Vec<Arc<KitsuneOpData>, Global>
) -> MustBoxFuture<'static, Result<(), KitsuneP2pError>> ⓘ
fn gossip(
&self,
space: Arc<KitsuneSpace>,
ops: Vec<Arc<KitsuneOpData>, Global>
) -> MustBoxFuture<'static, Result<(), KitsuneP2pError>> ⓘ
sourcefn query_op_hashes(
&self,
input: QueryOpHashesEvt
) -> MustBoxFuture<'static, Result<Option<(Vec<Arc<KitsuneOpHash>, Global>, RangeInclusive<Timestamp>)>, KitsuneP2pError>> ⓘ
fn query_op_hashes(
&self,
input: QueryOpHashesEvt
) -> MustBoxFuture<'static, Result<Option<(Vec<Arc<KitsuneOpHash>, Global>, RangeInclusive<Timestamp>)>, KitsuneP2pError>> ⓘ
sourcefn fetch_op_data(
&self,
input: FetchOpDataEvt
) -> MustBoxFuture<'static, Result<Vec<(Arc<KitsuneOpHash>, Arc<KitsuneOpData>), Global>, KitsuneP2pError>> ⓘ
fn fetch_op_data(
&self,
input: FetchOpDataEvt
) -> MustBoxFuture<'static, Result<Vec<(Arc<KitsuneOpHash>, Arc<KitsuneOpData>), Global>, KitsuneP2pError>> ⓘ
sourcefn sign_network_data(
&self,
input: SignNetworkDataEvt
) -> MustBoxFuture<'static, Result<KitsuneSignature, KitsuneP2pError>> ⓘ
fn sign_network_data(
&self,
input: SignNetworkDataEvt
) -> MustBoxFuture<'static, Result<KitsuneSignature, KitsuneP2pError>> ⓘ
sourceimpl<S> KitsuneP2pSender for Swhere
S: GhostChannelSender<KitsuneP2p>,
impl<S> KitsuneP2pSender for Swhere
S: GhostChannelSender<KitsuneP2p>,
sourcefn list_transport_bindings(
&self
) -> MustBoxFuture<'static, Result<Vec<Url2, Global>, KitsuneP2pError>> ⓘ
fn list_transport_bindings(
&self
) -> MustBoxFuture<'static, Result<Vec<Url2, Global>, KitsuneP2pError>> ⓘ
sourcefn join(
&self,
space: Arc<KitsuneSpace>,
agent: Arc<KitsuneAgent>,
initial_arc: Option<DhtArc>
) -> MustBoxFuture<'static, Result<(), KitsuneP2pError>> ⓘ
fn join(
&self,
space: Arc<KitsuneSpace>,
agent: Arc<KitsuneAgent>,
initial_arc: Option<DhtArc>
) -> MustBoxFuture<'static, Result<(), KitsuneP2pError>> ⓘ
sourcefn 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>> ⓘ
sourcefn rpc_single(
&self,
space: Arc<KitsuneSpace>,
to_agent: Arc<KitsuneAgent>,
payload: Vec<u8, Global>,
timeout_ms: Option<u64>
) -> MustBoxFuture<'static, Result<Vec<u8, Global>, KitsuneP2pError>> ⓘ
fn rpc_single(
&self,
space: Arc<KitsuneSpace>,
to_agent: Arc<KitsuneAgent>,
payload: Vec<u8, Global>,
timeout_ms: Option<u64>
) -> MustBoxFuture<'static, Result<Vec<u8, Global>, KitsuneP2pError>> ⓘ
sourcefn rpc_multi(
&self,
input: RpcMulti
) -> MustBoxFuture<'static, Result<Vec<RpcMultiResponse, Global>, KitsuneP2pError>> ⓘ
fn rpc_multi(
&self,
input: RpcMulti
) -> MustBoxFuture<'static, Result<Vec<RpcMultiResponse, Global>, KitsuneP2pError>> ⓘ
sourcefn broadcast(
&self,
space: Arc<KitsuneSpace>,
basis: Arc<KitsuneBasis>,
timeout: KitsuneTimeout,
destination: BroadcastTo,
payload: Vec<u8, Global>
) -> MustBoxFuture<'static, Result<(), KitsuneP2pError>> ⓘ
fn broadcast(
&self,
space: Arc<KitsuneSpace>,
basis: Arc<KitsuneBasis>,
timeout: KitsuneTimeout,
destination: BroadcastTo,
payload: Vec<u8, Global>
) -> MustBoxFuture<'static, Result<(), KitsuneP2pError>> ⓘ
sourcefn targeted_broadcast(
&self,
space: Arc<KitsuneSpace>,
agents: Vec<Arc<KitsuneAgent>, Global>,
timeout: KitsuneTimeout,
payload: Vec<u8, Global>,
drop_at_limit: bool
) -> MustBoxFuture<'static, Result<(), KitsuneP2pError>> ⓘ
fn targeted_broadcast(
&self,
space: Arc<KitsuneSpace>,
agents: Vec<Arc<KitsuneAgent>, Global>,
timeout: KitsuneTimeout,
payload: Vec<u8, Global>,
drop_at_limit: bool
) -> MustBoxFuture<'static, Result<(), KitsuneP2pError>> ⓘ
sourcefn new_integrated_data(
&self,
space: Arc<KitsuneSpace>
) -> MustBoxFuture<'static, Result<(), KitsuneP2pError>> ⓘ
fn new_integrated_data(
&self,
space: Arc<KitsuneSpace>
) -> MustBoxFuture<'static, Result<(), KitsuneP2pError>> ⓘ
sourcefn 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>> ⓘ
sourcefn get_diagnostics(
&self,
space: Arc<KitsuneSpace>
) -> MustBoxFuture<'static, Result<GossipDiagnostics, KitsuneP2pError>> ⓘ
fn get_diagnostics(
&self,
space: Arc<KitsuneSpace>
) -> MustBoxFuture<'static, Result<GossipDiagnostics, KitsuneP2pError>> ⓘ
impl<T> Pointable for T
impl<T> Pointable for T
impl<T, Item> SinkExt<Item> for Twhere
T: Sink<Item> + ?Sized,
impl<T, Item> SinkExt<Item> for Twhere
T: Sink<Item> + ?Sized,
fn with<U, Fut, F, E>(self, f: F) -> With<Self, Item, U, Fut, F>where
F: FnMut(U) -> Fut,
Fut: Future<Output = Result<Item, E>>,
E: From<Self::Error>,
Self: Sized,
fn with<U, Fut, F, E>(self, f: F) -> With<Self, Item, U, Fut, F>where
F: FnMut(U) -> Fut,
Fut: Future<Output = Result<Item, E>>,
E: From<Self::Error>,
Self: Sized,
fn with_flat_map<U, St, F>(self, f: F) -> WithFlatMap<Self, Item, U, St, F>where
F: FnMut(U) -> St,
St: Stream<Item = Result<Item, Self::Error>>,
Self: Sized,
fn with_flat_map<U, St, F>(self, f: F) -> WithFlatMap<Self, Item, U, St, F>where
F: FnMut(U) -> St,
St: Stream<Item = Result<Item, Self::Error>>,
Self: Sized,
fn sink_map_err<E, F>(self, f: F) -> SinkMapErr<Self, F>where
F: FnOnce(Self::Error) -> E,
Self: Sized,
fn sink_map_err<E, F>(self, f: F) -> SinkMapErr<Self, F>where
F: FnOnce(Self::Error) -> E,
Self: Sized,
fn sink_err_into<E>(self) -> SinkErrInto<Self, Item, E>where
Self: Sized,
Self::Error: Into<E>,
fn sink_err_into<E>(self) -> SinkErrInto<Self, Item, E>where
Self: Sized,
Self::Error: Into<E>,
Into
trait. Read morefn buffer(self, capacity: usize) -> Buffer<Self, Item>where
Self: Sized,
fn buffer(self, capacity: usize) -> Buffer<Self, Item>where
Self: Sized,
fn fanout<Si>(self, other: Si) -> Fanout<Self, Si>where
Self: Sized,
Item: Clone,
Si: Sink<Item, Error = Self::Error>,
fn fanout<Si>(self, other: Si) -> Fanout<Self, Si>where
Self: Sized,
Item: Clone,
Si: Sink<Item, Error = Self::Error>,
fn flush(&mut self) -> Flush<'_, Self, Item> ⓘwhere
Self: Unpin,
fn flush(&mut self) -> Flush<'_, Self, Item> ⓘwhere
Self: Unpin,
fn send(&mut self, item: Item) -> Send<'_, Self, Item> ⓘwhere
Self: Unpin,
fn send(&mut self, item: Item) -> Send<'_, Self, Item> ⓘwhere
Self: Unpin,
fn feed(&mut self, item: Item) -> Feed<'_, Self, Item> ⓘwhere
Self: Unpin,
fn feed(&mut self, item: Item) -> Feed<'_, Self, Item> ⓘwhere
Self: Unpin,
fn send_all<St, 'a>(&'a mut self, stream: &'a mut St) -> SendAll<'a, Self, St> ⓘwhere
St: TryStream<Ok = Item, Error = Self::Error> + Stream + Unpin + ?Sized,
Self: Unpin,
fn send_all<St, 'a>(&'a mut self, stream: &'a mut St) -> SendAll<'a, Self, St> ⓘwhere
St: TryStream<Ok = Item, Error = Self::Error> + Stream + Unpin + ?Sized,
Self: Unpin,
fn left_sink<Si2>(self) -> Either<Self, Si2> ⓘwhere
Si2: Sink<Item, Error = Self::Error>,
Self: Sized,
fn left_sink<Si2>(self) -> Either<Self, Si2> ⓘwhere
Si2: Sink<Item, Error = Self::Error>,
Self: Sized,
fn right_sink<Si1>(self) -> Either<Si1, Self> ⓘwhere
Si1: Sink<Item, Error = Self::Error>,
Self: Sized,
fn right_sink<Si1>(self) -> Either<Si1, Self> ⓘwhere
Si1: Sink<Item, Error = Self::Error>,
Self: Sized,
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,
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,
fn poll_flush_unpin(
&mut self,
cx: &mut Context<'_>
) -> Poll<Result<(), Self::Error>>where
Self: Unpin,
fn poll_flush_unpin(
&mut self,
cx: &mut Context<'_>
) -> Poll<Result<(), Self::Error>>where
Self: Unpin,
impl<Item, S> SinkRateLimitExt<Item, S> for Swhere
S: Sink<Item>,
impl<Item, S> SinkRateLimitExt<Item, S> for Swhere
S: Sink<Item>,
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,
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,
impl<SS, SP> SupersetOf<SS> for SPwhere
SS: SubsetOf<SP>,
impl<SS, SP> SupersetOf<SS> for SPwhere
SS: SubsetOf<SP>,
fn to_subset(&self) -> Option<SS>
fn to_subset(&self) -> Option<SS>
self
from the equivalent element of its
superset. Read morefn 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).fn to_subset_unchecked(&self) -> SS
fn to_subset_unchecked(&self) -> SS
self.to_subset
but without any property checks. Always succeeds.fn from_subset(element: &SS) -> SP
fn from_subset(element: &SS) -> SP
self
to the equivalent element of its superset.