pub struct Responder;Trait Implementations§
Source§impl<'de> Deserialize<'de> for Responder
impl<'de> Deserialize<'de> for Responder
Source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
Source§impl Ord for Responder
impl Ord for Responder
Source§impl PartialOrd for Responder
impl PartialOrd for Responder
Source§impl ProtocolState<Responder> for State
impl ProtocolState<Responder> for State
type WireMsg = Message
type Action = ResponderAction
type Out = ResponderResult
type Error = Void
fn init(&self) -> Result<(Outcome<Self::WireMsg, Self::Out, Self::Error>, Self)>
fn network( &self, input: Self::WireMsg, ) -> Result<(Outcome<Self::WireMsg, Self::Out, Self::Error>, Self)>
fn local( &self, input: Self::Action, ) -> Result<(Outcome<Self::WireMsg, Void, Self::Error>, Self)>
Source§impl ProtocolState<Responder> for State
impl ProtocolState<Responder> for State
type WireMsg = Message<VersionData>
type Action = ResponderAction
type Out = Proposal
type Error = Void
fn init(&self) -> Result<(Outcome<Self::WireMsg, Self::Out, Self::Error>, Self)>
fn network( &self, input: Self::WireMsg, ) -> Result<(Outcome<Self::WireMsg, Self::Out, Self::Error>, Self)>
fn local( &self, input: Self::Action, ) -> Result<(Outcome<Self::WireMsg, Void, Self::Error>, Self)>
Source§impl ProtocolState<Responder> for State
impl ProtocolState<Responder> for State
type WireMsg = Message
type Action = ResponderAction
type Out = ResponderResult
type Error = Void
fn init(&self) -> Result<(Outcome<Self::WireMsg, Self::Out, Self::Error>, Self)>
fn network( &self, input: Self::WireMsg, ) -> Result<(Outcome<Self::WireMsg, Self::Out, Self::Error>, Self)>
fn local( &self, input: Self::Action, ) -> Result<(Outcome<Self::WireMsg, Void, Self::Error>, Self)>
Source§impl ProtocolState<Responder> for State
impl ProtocolState<Responder> for State
type WireMsg = Message
type Action = ResponderAction
type Out = ResponderResult
type Error = ProtocolError
fn init(&self) -> Result<(Outcome<Self::WireMsg, Self::Out, Self::Error>, Self)>
fn network( &self, input: Self::WireMsg, ) -> Result<(Outcome<Self::WireMsg, Self::Out, Self::Error>, Self)>
fn local( &self, input: Self::Action, ) -> Result<(Outcome<Self::WireMsg, Void, Self::Error>, Self)>
Source§impl StageState<State, Responder> for BlockFetchResponder
impl StageState<State, Responder> for BlockFetchResponder
type LocalIn = StreamBlocks
async fn local( self, _proto: &State, input: Self::LocalIn, eff: &Effects<Inputs<Self::LocalIn>>, ) -> Result<(Option<ResponderAction>, Self)>
async fn network( self, _proto: &State, input: ResponderResult, eff: &Effects<Inputs<Self::LocalIn>>, ) -> Result<(Option<ResponderAction>, Self)>
fn muxer(&self) -> &StageRef<MuxMessage>
Source§impl StageState<State, Responder> for HandshakeResponder
impl StageState<State, Responder> for HandshakeResponder
type LocalIn = Void
async fn local( self, _proto: &State, input: Self::LocalIn, _eff: &Effects<Inputs<Self::LocalIn>>, ) -> Result<(Option<ResponderAction>, Self)>
async fn network( self, _proto: &State, input: Proposal, eff: &Effects<Inputs<Self::LocalIn>>, ) -> Result<(Option<ResponderAction>, Self)>
fn muxer(&self) -> &StageRef<MuxMessage>
impl Copy for Responder
impl Eq for Responder
impl StructuralPartialEq for Responder
Auto Trait Implementations§
impl Freeze for Responder
impl RefUnwindSafe for Responder
impl Send for Responder
impl Sync for Responder
impl Unpin for Responder
impl UnsafeUnpin for Responder
impl UnwindSafe for Responder
Blanket Implementations§
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
Mutably borrows from an owned value. Read more
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
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<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> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more