Struct Behaviour 

pub struct Behaviour {
    menu: Arc<BTreeSet<(RpcTag, Ver)>>,
    peers: BTreeMap<PeerId, ConnectionId>,
    queue: VecDeque<ToSwarm<(PeerId, Event), Command>>,
    pending: BTreeMap<PeerId, VecDeque<Command>>,
    waker: Option<Waker>,
}

Fields

menu: Arc<BTreeSet<(RpcTag, Ver)>>

peers: BTreeMap<PeerId, ConnectionId>

queue: VecDeque<ToSwarm<(PeerId, Event), Command>>

pending: BTreeMap<PeerId, VecDeque<Command>>

waker: Option<Waker>

Implementations

impl Behaviour

fn dispatch_command(&mut self, peer_id: PeerId, command: Command)

pub fn open(&mut self, peer_id: PeerId, outgoing_stream_id: u32)

pub fn respond<M>( &mut self, peer_id: PeerId, stream_id: StreamId, id: u64, response: Result<M::Response, Error>, ) -> Result<(), Error>

where M: RpcMethod,

pub fn query<M>( &mut self, peer_id: PeerId, stream_id: StreamId, id: u64, query: M::Query, ) -> Result<(), Error>

where M: RpcMethod,

Trait Implementations

impl Default for Behaviour

fn default() -> Behaviour

Returns the “default value” for a type.

impl NetworkBehaviour for Behaviour

type ConnectionHandler = Handler

Handler for all the protocols the network behaviour supports.

type ToSwarm = (PeerId, Event)

Event generated by the NetworkBehaviour and that the swarm will report back.

fn handle_established_inbound_connection( &mut self, connection_id: ConnectionId, peer: PeerId, _local_addr: &Multiaddr, _remote_addr: &Multiaddr, ) -> Result<THandler<Self>, ConnectionDenied>

Callback that is invoked for every established inbound connection.

fn handle_established_outbound_connection( &mut self, connection_id: ConnectionId, peer: PeerId, _addr: &Multiaddr, _role_override: Endpoint, ) -> Result<THandler<Self>, ConnectionDenied>

Callback that is invoked for every established outbound connection.

fn on_swarm_event(&mut self, event: FromSwarm<'_, Self::ConnectionHandler>)

Informs the behaviour about an event from the Swarm.

fn on_connection_handler_event( &mut self, peer_id: PeerId, connection_id: ConnectionId, event: THandlerOutEvent<Self>, )

Informs the behaviour about an event generated by the [ConnectionHandler] dedicated to the peer identified by peer_id. for the behaviour.

fn poll( &mut self, cx: &mut Context<'_>, _params: &mut impl PollParameters, ) -> Poll<ToSwarm<Self::ToSwarm, THandlerInEvent<Self>>>

Polls for things that swarm should do.

fn handle_pending_inbound_connection( &mut self, _connection_id: ConnectionId, _local_addr: &Multiaddr, _remote_addr: &Multiaddr, ) -> Result<(), ConnectionDenied>

Callback that is invoked for every new inbound connection.

fn handle_pending_outbound_connection( &mut self, _connection_id: ConnectionId, _maybe_peer: Option<PeerId>, _addresses: &[Multiaddr], _effective_role: Endpoint, ) -> Result<Vec<Multiaddr>, ConnectionDenied>

Callback that is invoked for every outbound connection attempt.