Struct CallSlot 

pub struct CallSlot { /* private fields */ }

Where a connector keeps its CallContext: its own settings, plus the context the pipeline installs.

Build it in new() from the connector’s config, forward Source::set_call_context / Sink::set_call_context to install, and run calls through call. Before the pipeline installs anything (a library caller driving the connector directly) the connector’s own settings and the defaults apply.

Implementations

impl CallSlot

pub fn new(local: CallContext) -> Self

A slot whose connector-owned settings are local.

pub fn local(&self) -> &CallContext

The connector-owned settings.

pub fn set_local(&mut self, local: CallContext)

Replace the connector-owned settings (from a builder method).

pub fn install(&self, ctx: CallContext)

Install the pipeline’s context. The first call wins.

pub fn install_recorder(&self, recorder: Arc<RoundtripRecorder>)

Install a round-trip recorder, used when the installed context carries none (a caller that only calls set_roundtrip_recorder). The first call wins.

pub fn get(&self) -> CallContext

The effective context: the connector’s settings over the installed context, with the separately installed recorder as a fallback.

pub fn recorder(&self) -> Option<Arc<RoundtripRecorder>>

The round-trip recorder in effect, if any.

pub fn record(&self, op: &'static str)

Count one round trip made outside call.

pub async fn wait(&self, duration: Duration) -> Result<(), FaucetError>

Wait through the effective context (CallContext::wait).

pub async fn call<T, F, Fut>( &self, op: &'static str, f: F, ) -> Result<T, FaucetError>

where F: FnMut() -> Fut, Fut: Future<Output = Result<T, FaucetError>>,

Run f through the effective context (CallContext::call).

pub async fn call_once<T, Fut>( &self, op: &'static str, fut: Fut, ) -> Result<T, FaucetError>

where Fut: Future<Output = Result<T, FaucetError>>,

Run fut once through the effective context (CallContext::call_once).

Trait Implementations

impl Debug for CallSlot

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

Formats the value using the given formatter.

impl Default for CallSlot

fn default() -> Self

Returns the “default value” for a type.

impl RefUnwindSafe for CallSlot

impl UnwindSafe for CallSlot