Struct LocalMockTransport 

pub struct LocalMockTransport<'a> { /* private fields */ }

Ordered mock transport whose futures are intentionally local-only.

The Cell marker makes this type !Sync, so futures borrowing it cannot be sent between threads. It exercises browser, embedded, and single-threaded executor integrations without adding an allocator or runtime dependency.

use cloud_sdk_testkit::LocalMockTransport;
fn require_sync<T: Sync>() {}
require_sync::<LocalMockTransport<'static>>();

Implementations

impl<'a> LocalMockTransport<'a>

pub const fn new(exchanges: &'a [MockExchange<'a>]) -> Self

Creates a local-only mock over an ordered exchange slice.

pub const fn with_endpoint(self, endpoint: EndpointIdentity<'a>) -> Self

Binds the mock permanently to one normalized endpoint identity.

pub const fn with_credential_binding(self, binding: CredentialBinding) -> Self

Selects a deterministic credential lineage for association tests.

pub fn remaining(&self) -> usize

Returns the number of exchanges not yet consumed.

pub fn is_complete(&self) -> bool

Reports whether every expected exchange was consumed.

Trait Implementations

impl BoundCredentialTransport for LocalMockTransport<'_>

fn credential_binding(&self) -> CredentialBinding

Returns the current transport credential lifecycle.

impl BoundTransport for LocalMockTransport<'_>

fn endpoint_identity( &self, ) -> Result<EndpointIdentity<'_>, EndpointIdentityError>

Returns the immutable normalized endpoint identity.

impl Debug for LocalMockTransport<'_>

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

Formats the value using the given formatter.

impl LocalAsyncAuthenticatedTransport for LocalMockTransport<'_>

type Error = MockError

Transport-specific failure.

async fn send_authenticated_local<'transport, 'request, 'policy, 'writer, 'buffer>( &'transport self, request: AuthenticatedRequest<'request, 'policy>, response: AsyncResponseStaging<'writer, 'buffer>, ) -> Result<ResponseCompletion, Self::Error>

where 'transport: 'writer, 'request: 'writer, 'policy: 'writer, 'buffer: 'writer,

Validates scope and sends one authenticated request locally.

impl LocalAsyncTransport for LocalMockTransport<'_>

type Error = MockError

Transport-specific failure.

async fn send_local<'transport, 'request, 'writer, 'buffer>( &'transport self, request: TransportRequest<'request>, response: AsyncResponseStaging<'writer, 'buffer>, ) -> Result<ResponseCompletion, Self::Error>

where 'transport: 'writer, 'request: 'writer, 'buffer: 'writer,

Stages one response without requiring the returned future to be Send.