Struct CollectSink 

pub struct CollectSink(/* private fields */);

An InboundSink that keeps every event, for adapter tests.

Implementations

impl CollectSink

pub fn events(&self) -> Vec<InboundEvent>

Events delivered so far.

pub async fn first(&self) -> InboundEvent

Waits up to 10 seconds for the first event.

Panics

When none arrives.

Trait Implementations

impl Debug for CollectSink

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

Formats the value using the given formatter.

impl Default for CollectSink

fn default() -> Self

Returns the “default value” for a type.

impl InboundSink for CollectSink

fn deliver<'life0, 'async_trait>( &'life0 self, event: InboundEvent, ) -> Pin<Box<dyn Future<Output = Result<(), SinkClosed>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Hands one event to the runtime. Returns quickly; processing happens elsewhere.

fn answer<'life0, 'async_trait>( &'life0 self, _answer: PromptAnswer, ) -> Pin<Box<dyn Future<Output = Result<(), SinkClosed>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

Hands over the answer to a Prompt. Returns quickly. Sinks without prompts ignore it.