Struct ScriptedUpstream 

pub struct ScriptedUpstream { /* private fields */ }

An in-process Upstream that serves a fixed script of responses in order.

This is the seam that keeps replay tests offline: instead of a network provider, a re-run’s cache-miss relays are answered from a queue the test set up. It hands out responses in FIFO order and reports UpstreamError::Exhausted once the script runs dry, so a test that under-scripts fails loudly rather than serving a stale answer.

Implementations

impl ScriptedUpstream

pub fn new(responses: impl IntoIterator<Item = CapturedResponse>) -> Self

A stub that will serve responses in order on successive cache misses.

Trait Implementations

impl Debug for ScriptedUpstream

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

Formats the value using the given formatter.

impl Upstream for ScriptedUpstream

fn send( &self, _request: &CapturedRequest, ) -> impl Future<Output = Result<CapturedResponse, UpstreamError>> + Send

Send request upstream and return the response.