Struct WireDriver 

pub struct WireDriver {
    pub provider: &'static str,
    /* private fields */
}

Available on crate feature test-utils and not (target_os=unknown and WebAssembly) only.

One provider’s full streaming pipeline over scripted wire chunks.

The closure builds a fresh provider client over a scripted HTTP double (SequencedStreamingHttpClient), opens CompletionModel::stream, drains it, and returns everything the consumer observed.

Fields

provider: &'static str

Stable descriptor name of the provider under test.

Implementations

impl WireDriver

pub fn new( provider: &'static str, drive: impl Fn(Vec<Result<WireInput, Error>>) -> Pin<Box<dyn Future<Output = Result<DrainedStream, CompletionError>> + Send>> + Send + Sync + 'static, ) -> WireDriver

Available on crate features test-utils only.

Wrap a provider pipeline closure.

pub async fn drive( &self, chunks: Vec<Result<WireInput, Error>>, ) -> Result<DrainedStream, CompletionError>

Available on crate features test-utils only.

Run the provider’s full pipeline over chunks and drain it.