Struct PluginChannel 

#[repr(C)]
pub struct PluginChannel {
    pub sender: RSender<PluginMsg_NE>,
    pub receiver: RReceiver<PluginMsg_NE>,
}

Fields

sender: RSender<PluginMsg_NE>

receiver: RReceiver<PluginMsg_NE>

Implementations

impl PluginChannel

pub fn new(channels: (RSender<PluginMsg_NE>, RReceiver<PluginMsg_NE>)) -> Self

pub async fn send_with_retry<CreatePayloadFn>( &self, runtime: &PluginAsyncRuntimeObj, op_name: &str, create_payload: CreatePayloadFn, ) -> Result<(), PluginError>

where CreatePayloadFn: Fn() -> PluginMsg_NE,

pub async fn send_with_retry_callback<CreatePayloadFn, OnRetryFn>( &self, runtime: &PluginAsyncRuntimeObj, op_name: &str, create_payload: CreatePayloadFn, on_retry: Option<OnRetryFn>, retry_delay: Duration, ) -> Result<(), PluginError>

where CreatePayloadFn: Fn() -> PluginMsg_NE, OnRetryFn: Fn() -> Pin<Box<dyn Future<Output = bool> + Send>>,

Send a message with retry logic if the channel is full. Uses try_send to avoid blocking the thread, and retries with a delay.

Arguments

• runtime - The async runtime for sleeping between retries
• op_name - Name used in error messages and logging
• create_payload - The function to create the payload to send. This is called every send attempt.
• on_retry - Optional callback executed on each retry attempt. Return false to stop retrying.

Trait Implementations

impl Clone for PluginChannel

fn clone(&self) -> PluginChannel

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PluginChannel

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

Formats the value using the given formatter.

impl GetStaticEquivalent_ for PluginChannel

type StaticEquivalent = _static_PluginChannel

The 'static equivalent of Self

impl StableAbi for PluginChannel

const LAYOUT: &'static TypeLayout

The layout of the type provided by implementors.

type IsNonZeroType = False

Whether this type has a single invalid bit-pattern.

const ABI_CONSTS: AbiConsts = _

const-equivalents of the associated types.