Struct TestSubscriberProbe 

pub struct TestSubscriberProbe<T> { /* private fields */ }

Implementations

impl<T> TestSubscriberProbe<T>

pub fn set_timeout(&mut self, timeout: Duration)

pub fn request(&self, n: usize)

pub fn expect_next(&self) -> T

pub fn assert_next(&self, expected: T)

where T: Debug + PartialEq,

pub fn expect_next_n(&self, n: usize) -> Vec<T>

pub fn assert_next_n<I>(&self, expected: I)

where T: Debug + PartialEq, I: IntoIterator<Item = T>,

pub fn expect_complete(&self)

Expects stream completion after a downstream pull has been issued.

Datum’s probes observe terminal signals through the normal pull loop, so completion is not surfaced until a credit is outstanding. For empty sources, call request(1) before expect_complete().

pub fn expect_error(&self) -> StreamError

Expects a stream error after a downstream pull has been issued.

Datum’s probes observe terminal signals through the normal pull loop, so an immediately failed source still requires request(1) before expect_error().

pub fn expect_no_message(&self, timeout: Duration)

pub fn drain_until_complete(&self) -> Vec<T>

Drains all remaining queued events until stream completion, returning every collected value. Uses the probe’s configured timeout for each event wait. Panics if the stream fails instead of completing.

This is load-robust: it drains every Next event before expecting Complete, so it tolerates operators that may emit extra elements under thread contention without the test needing to know the exact count ahead of time.

pub fn cancel(&mut self)

Cancels the sink probe.

Cancellation is observed at the worker’s next credit wait. If the worker is already blocked inside upstream next(), it will unblock when upstream yields or when an upstream test source probe is dropped.

Trait Implementations

impl<T> Drop for TestSubscriberProbe<T>

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.