pub enum State {
Idle,
Busy,
Streaming,
Done,
}Variants§
Trait Implementations§
Source§impl<'de> Deserialize<'de> for State
impl<'de> Deserialize<'de> for State
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 State
impl Ord for State
Source§impl PartialOrd for State
impl PartialOrd for State
Source§impl ProtocolState<Initiator> for State
impl ProtocolState<Initiator> for State
type WireMsg = Message
type Action = InitiatorAction
type Out = InitiatorResult
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 StageState<State, Initiator> for BlockFetchInitiator
impl StageState<State, Initiator> for BlockFetchInitiator
type LocalIn = BlockFetchMessage
async fn local( self, proto: &State, input: Self::LocalIn, _eff: &Effects<Inputs<Self::LocalIn>>, ) -> Result<(Option<InitiatorAction>, Self)>
async fn network( self, _proto: &State, input: InitiatorResult, eff: &Effects<Inputs<Self::LocalIn>>, ) -> Result<(Option<InitiatorAction>, Self)>
fn muxer(&self) -> &StageRef<MuxMessage>
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>
impl Copy for State
impl Eq for State
impl StructuralPartialEq for State
Auto Trait Implementations§
impl Freeze for State
impl RefUnwindSafe for State
impl Send for State
impl Sync for State
impl Unpin for State
impl UnsafeUnpin for State
impl UnwindSafe for State
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