[−][src]Struct xaynet::state_machine::events::EventPublisher
A convenience type to emit any coordinator event.
Implementations
impl EventPublisher
[src]
pub fn init(
keys: EncryptKeyPair,
params: RoundParameters,
phase: PhaseName
) -> (Self, EventSubscriber)
[src]
keys: EncryptKeyPair,
params: RoundParameters,
phase: PhaseName
) -> (Self, EventSubscriber)
Initialize a new event publisher with the given initial events.
pub fn broadcast_keys(&mut self, round_id: RoundSeed, keys: EncryptKeyPair)
[src]
Emit a keys event
pub fn broadcast_params(&mut self, params: RoundParameters)
[src]
Emit a round parameters event
pub fn broadcast_phase(&mut self, round_id: RoundSeed, phase: PhaseName)
[src]
Emit a phase event
pub fn broadcast_scalar(&mut self, round_id: RoundSeed, update: ScalarUpdate)
[src]
Emit a scalar event
pub fn broadcast_model(&mut self, round_id: RoundSeed, update: ModelUpdate)
[src]
Emit a model event
pub fn broadcast_mask_length(
&mut self,
round_id: RoundSeed,
update: MaskLengthUpdate
)
[src]
&mut self,
round_id: RoundSeed,
update: MaskLengthUpdate
)
Emit a mask_length event
pub fn broadcast_sum_dict(
&mut self,
round_id: RoundSeed,
update: DictionaryUpdate<SumDict>
)
[src]
&mut self,
round_id: RoundSeed,
update: DictionaryUpdate<SumDict>
)
Emit a sum dictionary update
pub fn broadcast_seed_dict(
&mut self,
round_id: RoundSeed,
update: DictionaryUpdate<SeedDict>
)
[src]
&mut self,
round_id: RoundSeed,
update: DictionaryUpdate<SeedDict>
)
Emit a seed dictionary update
Trait Implementations
Auto Trait Implementations
impl !RefUnwindSafe for EventPublisher
impl Send for EventPublisher
impl Sync for EventPublisher
impl Unpin for EventPublisher
impl !UnwindSafe for EventPublisher
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> From<T> for T
[src]
impl<T> Instrument for T
[src]
fn instrument(self, span: Span) -> Instrumented<Self>
[src]
fn in_current_span(self) -> Instrumented<Self>
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T> Same<T> for T
type Output = T
Should always be Self
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
V: MultiLane<T>,
fn vzip(self) -> V
impl<T> WithSubscriber for T
[src]
fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
[src]
S: Into<Dispatch>,