Enum P2pChannelsStreamingRpcState

pub enum P2pChannelsStreamingRpcState {
    Disabled,
    Enabled,
    Init {
        time: Timestamp,
    },
    Pending {
        time: Timestamp,
    },
    Ready {
        time: Timestamp,
        local: P2pStreamingRpcLocalState,
        remote: P2pStreamingRpcRemoteState,
        remote_last_responded: Timestamp,
    },
}

Variants

Disabled

Enabled

Init

Fields

time: Timestamp

Pending

Fields

time: Timestamp

Ready

Fields

time: Timestamp

local: P2pStreamingRpcLocalState

We are the requestors here.

remote: P2pStreamingRpcRemoteState

We are the responders here.

remote_last_responded: Timestamp

Implementations

impl P2pChannelsStreamingRpcState

pub fn is_ready(&self) -> bool

pub fn can_send_request(&self) -> bool

pub fn is_timed_out( &self, rpc_id: u64, now: Timestamp, config: &P2pTimeouts, ) -> bool

pub fn pending_local_rpc_id(&self) -> Option<u64>

pub fn pending_local_rpc(&self) -> Option<&P2pStreamingRpcRequest>

pub fn pending_local_rpc_kind(&self) -> Option<P2pStreamingRpcKind>

pub fn pending_local_rpc_progress( &self, ) -> Option<&P2pStreamingRpcReceiveProgress>

pub fn local_responded_request(&self) -> Option<(u64, &P2pStreamingRpcRequest)>

pub fn remote_todo_request(&self) -> Option<(u64, &P2pStreamingRpcRequest)>

pub fn remote_pending_request(&self) -> Option<(u64, &P2pStreamingRpcRequest)>

pub fn remote_next_msg(&self) -> Option<P2pStreamingRpcResponse>

pub fn remote_last_responded(&self) -> Timestamp

impl P2pChannelsStreamingRpcState

pub fn reducer<Action, State>( state_context: Substate<'_, Action, State, P2pState>, action: ActionWithMeta<P2pChannelsStreamingRpcAction>, ) -> Result<(), String>

where State: P2pStateTrait, Action: P2pActionTrait<State>,

Trait Implementations

impl Clone for P2pChannelsStreamingRpcState

fn clone(&self) -> P2pChannelsStreamingRpcState

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for P2pChannelsStreamingRpcState

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for P2pChannelsStreamingRpcState

fn deserialize<__D>( __deserializer: __D, ) -> Result<P2pChannelsStreamingRpcState, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for P2pChannelsStreamingRpcState

fn serialize<__S>( &self, __serializer: __S, ) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.