[−][src]Struct adbfbinlib::net::sm_behaviour::SMBehaviour

[+] Show declaration

pub struct SMBehaviour {
    sm: StateMachine<AdbfStateChart>,
    own_peer: PeerId,
    send_buffer: VecDeque<SMOutEvents>,
    ipc_receiver: Receiver<IPC>,
}

Fields

sm: StateMachine<AdbfStateChart>own_peer: PeerIdsend_buffer: VecDeque<SMOutEvents>ipc_receiver: Receiver<IPC>

Implementations

`impl SMBehaviour`[src][−]

`pub fn new( ipc_receiver: Receiver<IPC>, own_peer: PeerId, ui_data: UiData ) -> Self`[src]

`pub fn own_peer(&self) -> PeerId`[src]

`pub fn mdns_new_peer(&mut self, peer_id: &PeerId, multi_addr: &Multiaddr)`[src]

`pub fn mdns_remove(&mut self, peer_id: &PeerId)`[src]

`pub fn update_peer_data( &mut self, peer_id: &PeerId, data: IFCollectionOutputData )`[src]

`fn process_and_react(&mut self, event: Events)`[src]

Trait Implementations

`impl NetworkBehaviour for SMBehaviour`[src][+]

This is an almost empty SMBehaviour, but callable and with a return OutEvent and a queue that holds the Polling event, and can be influenced. It basically lacks all higher network behaviors, but that was just needed. todo: look how to handle #[behaviour(poll_method = "poll")]

[−][src]Struct adbfbinlib::net::sm_behaviour::SMBehaviour

Fields

Implementations

impl SMBehaviour[src][−]

pub fn new( ipc_receiver: Receiver<IPC>, own_peer: PeerId, ui_data: UiData) -> Self[src]

pub fn own_peer(&self) -> PeerId[src]

pub fn mdns_new_peer(&mut self, peer_id: &PeerId, multi_addr: &Multiaddr)[src]

pub fn mdns_remove(&mut self, peer_id: &PeerId)[src]

pub fn update_peer_data( &mut self, peer_id: &PeerId, data: IFCollectionOutputData)[src]

fn process_and_react(&mut self, event: Events)[src]

Trait Implementations

impl NetworkBehaviour for SMBehaviour[src][+]

type ProtocolsHandler = DummyProtocolsHandler

type OutEvent = SMOutEvents

fn new_handler(&mut self) -> Self::ProtocolsHandler[src][−]

fn addresses_of_peer(&mut self, _: &PeerId) -> Vec<Multiaddr>[src][−]

fn inject_connected(&mut self, _: &PeerId)[src][−]

fn inject_disconnected(&mut self, _: &PeerId)[src][−]

fn inject_connection_established( &mut self, _: &PeerId, _: &ConnectionId, _: &ConnectedPoint)[src][−]

fn inject_connection_closed( &mut self, _: &PeerId, _: &ConnectionId, _: &ConnectedPoint)[src][−]

fn inject_event( &mut self, _: PeerId, _: ConnectionId, _: <Self::ProtocolsHandler as ProtocolsHandler>::OutEvent)[src][−]

fn poll( &mut self, _: &mut Context<'_>, _: &mut impl PollParameters) -> Poll<NetworkBehaviourAction<<Self::ProtocolsHandler as ProtocolsHandler>::InEvent, Self::OutEvent>>[src][−]

pub fn inject_address_change( &mut self, &PeerId, &ConnectionId, _old: &ConnectedPoint, _new: &ConnectedPoint)[−]

pub fn inject_addr_reach_failure( &mut self, _peer_id: Option<&PeerId>, _addr: &Multiaddr, _error: &dyn Error)[−]

pub fn inject_dial_failure(&mut self, _peer_id: &PeerId)[−]

pub fn inject_new_listen_addr(&mut self, _addr: &Multiaddr)[−]

pub fn inject_expired_listen_addr(&mut self, _addr: &Multiaddr)[−]

pub fn inject_new_external_addr(&mut self, _addr: &Multiaddr)[−]

pub fn inject_listener_error( &mut self, _id: ListenerId, _err: &(dyn Error + 'static))[−]

pub fn inject_listener_closed( &mut self, _id: ListenerId, _reason: Result<(), &Error>)[−]

Auto Trait Implementations

impl RefUnwindSafe for SMBehaviour[src]

impl Send for SMBehaviour[src]

impl Sync for SMBehaviour[src]

impl Unpin for SMBehaviour[src]

impl UnwindSafe for SMBehaviour[src]

Blanket Implementations

impl<T> Any for T where T: 'static + ?Sized, [src][+]

pub fn type_id(&self) -> TypeId[src][−]

impl<T> Borrow<T> for T where T: ?Sized, [src][+]

pub fn borrow(&self) -> &T[src][−]

impl<T> BorrowMut<T> for T where T: ?Sized, [src][+]

pub fn borrow_mut(&mut self) -> &mut T[src][−]

impl<T> Conv for T[+]

pub fn conv<T>(self) -> T where Self: Into<T>, [−]

impl<T> Conv for T[+]

pub fn conv<T>(self) -> T where Self: Into<T>, [−]

impl<T> Erased for T

impl<T> FmtForward for T[+]

pub fn fmt_binary(self) -> FmtBinary<Self> where Self: Binary, [−]

pub fn fmt_display(self) -> FmtDisplay<Self> where Self: Display, [−]

pub fn fmt_lower_exp(self) -> FmtLowerExp<Self> where Self: LowerExp, [−]

pub fn fmt_lower_hex(self) -> FmtLowerHex<Self> where Self: LowerHex, [−]

pub fn fmt_octal(self) -> FmtOctal<Self> where Self: Octal, [−]

pub fn fmt_pointer(self) -> FmtPointer<Self> where Self: Pointer, [−]

pub fn fmt_upper_exp(self) -> FmtUpperExp<Self> where Self: UpperExp, [−]

pub fn fmt_upper_hex(self) -> FmtUpperHex<Self> where Self: UpperHex, [−]

impl<T> From<T> for T[src][+]

pub fn from(t: T) -> T[src][−]

impl<T> Instrument for T[src][+]

pub fn instrument(self, span: Span) -> Instrumented<Self>[src][−]

pub fn in_current_span(self) -> Instrumented<Self>[src][−]

impl<T> Instrument for T[src][+]

pub fn instrument(self, span: Span) -> Instrumented<Self>[src][−]

pub fn in_current_span(self) -> Instrumented<Self>[src][−]

impl<T, U> Into<U> for T where U: From<T>, [src][+]

pub fn into(self) -> U[src][−]

impl<T> Pipe for T where T: ?Sized, [+]

pub fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> R[−]

pub fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> R where R: 'a, [−]

pub fn pipe_ref_mut<'a, R>( &'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> R where R: 'a, [−]

pub fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R where Self: Borrow<B>, B: 'a + ?Sized, R: 'a, [−]

pub fn pipe_borrow_mut<'a, B, R>( &'a mut self, func: impl FnOnce(&'a mut B) -> R) -> R where Self: BorrowMut<B>, B: 'a + ?Sized, R: 'a, [−]

pub fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R where Self: AsRef<U>, R: 'a, U: 'a + ?Sized, [−]

pub fn pipe_as_mut<'a, U, R>( &'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R where Self: AsMut<U>, R: 'a, U: 'a + ?Sized, [−]

pub fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R where Self: Deref<Target = T>, T: 'a + ?Sized, R: 'a, [−]

pub fn pipe_deref_mut<'a, T, R>( &'a mut self, func: impl FnOnce(&'a mut T) -> R) -> R where Self: DerefMut<Target = T> + Deref, T: 'a + ?Sized, R: 'a, [−]

impl<T> Pipe for T[+]

pub fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> R[−]

impl<T> PipeAsRef for T[+]

`impl SMBehaviour`[src][−]

`pub fn new( ipc_receiver: Receiver<IPC>, own_peer: PeerId, ui_data: UiData ) -> Self`[src]

`pub fn own_peer(&self) -> PeerId`[src]

`pub fn mdns_new_peer(&mut self, peer_id: &PeerId, multi_addr: &Multiaddr)`[src]

`pub fn mdns_remove(&mut self, peer_id: &PeerId)`[src]

`pub fn update_peer_data( &mut self, peer_id: &PeerId, data: IFCollectionOutputData )`[src]

`fn process_and_react(&mut self, event: Events)`[src]

`impl NetworkBehaviour for SMBehaviour`[src][+]

`type ProtocolsHandler = DummyProtocolsHandler`

`type OutEvent = SMOutEvents`

`fn new_handler(&mut self) -> Self::ProtocolsHandler`[src][−]

`fn addresses_of_peer(&mut self, _: &PeerId) -> Vec<Multiaddr>`[src][−]

`fn inject_connected(&mut self, _: &PeerId)`[src][−]

`fn inject_disconnected(&mut self, _: &PeerId)`[src][−]

`fn inject_connection_established( &mut self, _: &PeerId, _: &ConnectionId, _: &ConnectedPoint )`[src][−]

`fn inject_connection_closed( &mut self, _: &PeerId, _: &ConnectionId, _: &ConnectedPoint )`[src][−]

`fn inject_event( &mut self, _: PeerId, _: ConnectionId, _: <Self::ProtocolsHandler as ProtocolsHandler>::OutEvent )`[src][−]

`fn poll( &mut self, _: &mut Context<'_>, _: &mut impl PollParameters ) -> Poll<NetworkBehaviourAction<<Self::ProtocolsHandler as ProtocolsHandler>::InEvent, Self::OutEvent>>`[src][−]

`pub fn inject_address_change( &mut self, &PeerId, &ConnectionId, _old: &ConnectedPoint, _new: &ConnectedPoint )`[−]

`pub fn inject_addr_reach_failure( &mut self, _peer_id: Option<&PeerId>, _addr: &Multiaddr, _error: &dyn Error )`[−]

`pub fn inject_dial_failure(&mut self, _peer_id: &PeerId)`[−]

`pub fn inject_new_listen_addr(&mut self, _addr: &Multiaddr)`[−]

`pub fn inject_expired_listen_addr(&mut self, _addr: &Multiaddr)`[−]

`pub fn inject_new_external_addr(&mut self, _addr: &Multiaddr)`[−]

`pub fn inject_listener_error( &mut self, _id: ListenerId, _err: &(dyn Error + 'static) )`[−]

`pub fn inject_listener_closed( &mut self, _id: ListenerId, _reason: Result<(), &Error> )`[−]

`impl RefUnwindSafe for SMBehaviour`[src]

`impl Send for SMBehaviour`[src]

`impl Sync for SMBehaviour`[src]

`impl Unpin for SMBehaviour`[src]

`impl UnwindSafe for SMBehaviour`[src]

`impl<T> Any for T where T: 'static + ?Sized,` [src][+]

`pub fn type_id(&self) -> TypeId`[src][−]

`impl<T> Borrow<T> for T where T: ?Sized,` [src][+]

`pub fn borrow(&self) -> &T`[src][−]

`impl<T> BorrowMut<T> for T where T: ?Sized,` [src][+]

`pub fn borrow_mut(&mut self) -> &mut T`[src][−]

`impl<T> Conv for T`[+]

`pub fn conv<T>(self) -> T where Self: Into<T>,` [−]

`impl<T> Conv for T`[+]

`pub fn conv<T>(self) -> T where Self: Into<T>,` [−]

`impl<T> Erased for T`

`impl<T> FmtForward for T`[+]

`pub fn fmt_binary(self) -> FmtBinary<Self> where Self: Binary,` [−]

`pub fn fmt_display(self) -> FmtDisplay<Self> where Self: Display,` [−]

`pub fn fmt_lower_exp(self) -> FmtLowerExp<Self> where Self: LowerExp,` [−]

`pub fn fmt_lower_hex(self) -> FmtLowerHex<Self> where Self: LowerHex,` [−]

`pub fn fmt_octal(self) -> FmtOctal<Self> where Self: Octal,` [−]

`pub fn fmt_pointer(self) -> FmtPointer<Self> where Self: Pointer,` [−]

`pub fn fmt_upper_exp(self) -> FmtUpperExp<Self> where Self: UpperExp,` [−]

`pub fn fmt_upper_hex(self) -> FmtUpperHex<Self> where Self: UpperHex,` [−]

`impl<T> From<T> for T`[src][+]

`pub fn from(t: T) -> T`[src][−]

`impl<T> Instrument for T`[src][+]

`pub fn instrument(self, span: Span) -> Instrumented<Self>`[src][−]

`pub fn in_current_span(self) -> Instrumented<Self>`[src][−]

`impl<T> Instrument for T`[src][+]

`pub fn instrument(self, span: Span) -> Instrumented<Self>`[src][−]

`pub fn in_current_span(self) -> Instrumented<Self>`[src][−]

`impl<T, U> Into<U> for T where U: From<T>,` [src][+]

`pub fn into(self) -> U`[src][−]

`impl<T> Pipe for T where T: ?Sized,` [+]

`pub fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> R`[−]

`pub fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> R where R: 'a,` [−]

`pub fn pipe_ref_mut<'a, R>( &'a mut self, func: impl FnOnce(&'a mut Self) -> R ) -> R where R: 'a,` [−]

`pub fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R where Self: Borrow<B>, B: 'a + ?Sized, R: 'a,` [−]

`pub fn pipe_borrow_mut<'a, B, R>( &'a mut self, func: impl FnOnce(&'a mut B) -> R ) -> R where Self: BorrowMut<B>, B: 'a + ?Sized, R: 'a,` [−]

`pub fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R where Self: AsRef<U>, R: 'a, U: 'a + ?Sized,` [−]

`pub fn pipe_as_mut<'a, U, R>( &'a mut self, func: impl FnOnce(&'a mut U) -> R ) -> R where Self: AsMut<U>, R: 'a, U: 'a + ?Sized,` [−]

`pub fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R where Self: Deref<Target = T>, T: 'a + ?Sized, R: 'a,` [−]

`pub fn pipe_deref_mut<'a, T, R>( &'a mut self, func: impl FnOnce(&'a mut T) -> R ) -> R where Self: DerefMut<Target = T> + Deref, T: 'a + ?Sized, R: 'a,` [−]

`impl<T> Pipe for T`[+]

`pub fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> R`[−]

`impl<T> PipeAsRef for T`[+]

`pub fn pipe_as_ref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R where Self: AsRef<T>, T: 'a, R: 'a,` [−]

`pub fn pipe_as_mut<'a, T, R>( &'a mut self, func: impl FnOnce(&'a mut T) -> R ) -> R where Self: AsMut<T>, T: 'a, R: 'a,` [−]

`impl<T> PipeBorrow for T`[+]

`pub fn pipe_borrow<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R where Self: Borrow<T>, T: 'a, R: 'a,` [−]

`pub fn pipe_borrow_mut<'a, T, R>( &'a mut self, func: impl FnOnce(&'a mut T) -> R ) -> R where Self: BorrowMut<T>, T: 'a, R: 'a,` [−]

`impl<T> PipeDeref for T`[+]