pub struct DynamicMockTransport<'fixture, 'records, B> { /* private fields */ }Expand description
Bounded allocation-free dynamic mock transport.
Implementations§
Source§impl<'fixture, 'records, B> DynamicMockTransport<'fixture, 'records, B>
impl<'fixture, 'records, B> DynamicMockTransport<'fixture, 'records, B>
Sourcepub fn new(
builder: B,
records: &'records [RequestRecordSlot],
) -> Result<Self, DynamicMockConfigError>
pub fn new( builder: B, records: &'records [RequestRecordSlot], ) -> Result<Self, DynamicMockConfigError>
Creates a dynamic mock over clean caller-owned record slots.
Sourcepub const fn with_endpoint(self, endpoint: EndpointIdentity<'fixture>) -> Self
pub const fn with_endpoint(self, endpoint: EndpointIdentity<'fixture>) -> Self
Binds the mock permanently to one normalized endpoint identity.
Sourcepub fn record(&self, index: usize) -> Option<RecordedRequest>
pub fn record(&self, index: usize) -> Option<RecordedRequest>
Returns one committed payload-free observation.
Trait Implementations§
Source§impl<'fixture, B> AsyncAuthenticatedTransport for DynamicMockTransport<'fixture, '_, B>where
B: ProviderFixtureBuilder<'fixture> + Sync,
impl<'fixture, B> AsyncAuthenticatedTransport for DynamicMockTransport<'fixture, '_, B>where
B: ProviderFixtureBuilder<'fixture> + Sync,
Source§type Error = DynamicMockError<<B as ProviderFixtureBuilder<'fixture>>::Error>
type Error = DynamicMockError<<B as ProviderFixtureBuilder<'fixture>>::Error>
Transport-specific failure.
Source§async fn send_authenticated<'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,
async fn send_authenticated<'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 stages one authenticated response.
Source§impl<'fixture, B> AsyncTransport for DynamicMockTransport<'fixture, '_, B>where
B: ProviderFixtureBuilder<'fixture> + Sync,
impl<'fixture, B> AsyncTransport for DynamicMockTransport<'fixture, '_, B>where
B: ProviderFixtureBuilder<'fixture> + Sync,
Source§type Error = DynamicMockError<<B as ProviderFixtureBuilder<'fixture>>::Error>
type Error = DynamicMockError<<B as ProviderFixtureBuilder<'fixture>>::Error>
Transport-specific failure.
Source§async fn send<'transport, 'request, 'writer, 'buffer>(
&'transport self,
request: TransportRequest<'request>,
response: AsyncResponseStaging<'writer, 'buffer>,
) -> Result<ResponseCompletion, Self::Error>where
'transport: 'writer,
'request: 'writer,
'buffer: 'writer,
async fn send<'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 complete response without committing it.
Source§impl<'fixture, B> BlockingAuthenticatedTransport for DynamicMockTransport<'fixture, '_, B>where
B: ProviderFixtureBuilder<'fixture>,
impl<'fixture, B> BlockingAuthenticatedTransport for DynamicMockTransport<'fixture, '_, B>where
B: ProviderFixtureBuilder<'fixture>,
Source§type Error = DynamicMockError<<B as ProviderFixtureBuilder<'fixture>>::Error>
type Error = DynamicMockError<<B as ProviderFixtureBuilder<'fixture>>::Error>
Transport-specific failure.
Source§fn send_authenticated(
&self,
request: AuthenticatedRequest<'_, '_>,
response: &mut ResponseWriter<'_>,
) -> Result<(), Self::Error>
fn send_authenticated( &self, request: AuthenticatedRequest<'_, '_>, response: &mut ResponseWriter<'_>, ) -> Result<(), Self::Error>
Validates scope and sends one authenticated request.
Source§impl<'fixture, B> BlockingTransport for DynamicMockTransport<'fixture, '_, B>where
B: ProviderFixtureBuilder<'fixture>,
impl<'fixture, B> BlockingTransport for DynamicMockTransport<'fixture, '_, B>where
B: ProviderFixtureBuilder<'fixture>,
Source§type Error = DynamicMockError<<B as ProviderFixtureBuilder<'fixture>>::Error>
type Error = DynamicMockError<<B as ProviderFixtureBuilder<'fixture>>::Error>
Transport-specific failure.
Source§fn send(
&self,
request: TransportRequest<'_>,
response: &mut ResponseWriter<'_>,
) -> Result<(), Self::Error>
fn send( &self, request: TransportRequest<'_>, response: &mut ResponseWriter<'_>, ) -> Result<(), Self::Error>
Sends one request and writes the response body into the caller buffer. Read more
Source§impl<B> BoundTransport for DynamicMockTransport<'_, '_, B>
impl<B> BoundTransport for DynamicMockTransport<'_, '_, B>
Source§fn endpoint_identity(
&self,
) -> Result<EndpointIdentity<'_>, EndpointIdentityError>
fn endpoint_identity( &self, ) -> Result<EndpointIdentity<'_>, EndpointIdentityError>
Returns the immutable normalized endpoint identity.
Auto Trait Implementations§
impl<'fixture, 'records, B> !Freeze for DynamicMockTransport<'fixture, 'records, B>
impl<'fixture, 'records, B> RefUnwindSafe for DynamicMockTransport<'fixture, 'records, B>where
B: RefUnwindSafe,
impl<'fixture, 'records, B> Send for DynamicMockTransport<'fixture, 'records, B>where
B: Send,
impl<'fixture, 'records, B> Sync for DynamicMockTransport<'fixture, 'records, B>where
B: Sync,
impl<'fixture, 'records, B> Unpin for DynamicMockTransport<'fixture, 'records, B>where
B: Unpin,
impl<'fixture, 'records, B> UnsafeUnpin for DynamicMockTransport<'fixture, 'records, B>where
B: UnsafeUnpin,
impl<'fixture, 'records, B> UnwindSafe for DynamicMockTransport<'fixture, 'records, B>where
B: UnwindSafe,
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> LocalAsyncAuthenticatedTransport for Twhere
T: AsyncAuthenticatedTransport + ?Sized,
impl<T> LocalAsyncAuthenticatedTransport for Twhere
T: AsyncAuthenticatedTransport + ?Sized,
Source§type Error = <T as AsyncAuthenticatedTransport>::Error
type Error = <T as AsyncAuthenticatedTransport>::Error
Transport-specific failure.
Source§async fn send_authenticated_local<'transport, 'request, 'policy, 'writer, 'buffer>(
&'transport self,
request: AuthenticatedRequest<'request, 'policy>,
response: AsyncResponseStaging<'writer, 'buffer>,
) -> Result<ResponseCompletion, <T as LocalAsyncAuthenticatedTransport>::Error>where
'transport: 'writer,
'request: 'writer,
'policy: 'writer,
'buffer: 'writer,
async fn send_authenticated_local<'transport, 'request, 'policy, 'writer, 'buffer>(
&'transport self,
request: AuthenticatedRequest<'request, 'policy>,
response: AsyncResponseStaging<'writer, 'buffer>,
) -> Result<ResponseCompletion, <T as LocalAsyncAuthenticatedTransport>::Error>where
'transport: 'writer,
'request: 'writer,
'policy: 'writer,
'buffer: 'writer,
Validates scope and sends one authenticated request locally.
Source§impl<T> LocalAsyncTransport for Twhere
T: AsyncTransport + ?Sized,
impl<T> LocalAsyncTransport for Twhere
T: AsyncTransport + ?Sized,
Source§type Error = <T as AsyncTransport>::Error
type Error = <T as AsyncTransport>::Error
Transport-specific failure.
Source§async fn send_local<'transport, 'request, 'writer, 'buffer>(
&'transport self,
request: TransportRequest<'request>,
response: AsyncResponseStaging<'writer, 'buffer>,
) -> Result<ResponseCompletion, <T as LocalAsyncTransport>::Error>where
'transport: 'writer,
'request: 'writer,
'buffer: 'writer,
async fn send_local<'transport, 'request, 'writer, 'buffer>(
&'transport self,
request: TransportRequest<'request>,
response: AsyncResponseStaging<'writer, 'buffer>,
) -> Result<ResponseCompletion, <T as LocalAsyncTransport>::Error>where
'transport: 'writer,
'request: 'writer,
'buffer: 'writer,
Stages one response without requiring the returned future to be
Send.