Struct aws_smithy_http_tower::parse_response::ParseResponseService

pub struct ParseResponseService<S, O, R> { /* private fields */ }

ParseResponseService dispatches Operations and parses them.

ParseResponseService is intended to wrap a DispatchService which will handle the interface between services that operate on operation::Request and services that operate on http::Request.

Trait Implementations

impl<S: Clone, O: Clone, R: Clone> Clone for ParseResponseService<S, O, R>

fn clone(&self) -> ParseResponseService<S, O, R>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<InnerService, ResponseHandler, SuccessResponse, FailureResponse, RetryPolicy> Service<Operation<ResponseHandler, RetryPolicy>> for ParseResponseService<InnerService, ResponseHandler, RetryPolicy>where
    InnerService: Service<Request, Response = Response, Error = SendOperationError>,
    InnerService::Future: Send + 'static,
    ResponseHandler: ParseHttpResponse<Output = Result<SuccessResponse, FailureResponse>> + Send + Sync + 'static,
    FailureResponse: Error + 'static,

ParseResponseService

Generic Parameter Listing: S: The inner service O: The type of the response parser whose output type is Result<T, E> T: The happy path return of the response parser E: The error path return of the response parser R: The type of the retry policy

type Response = SdkSuccess<SuccessResponse>

Responses given by the service.

type Error = SdkError<FailureResponse, Response>

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<<ParseResponseService<InnerService, ResponseHandler, RetryPolicy> as Service<Operation<ResponseHandler, RetryPolicy>>>::Response, <ParseResponseService<InnerService, ResponseHandler, RetryPolicy> as Service<Operation<ResponseHandler, RetryPolicy>>>::Error>> + Send + 'static, Global>>

The future response value.

fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>

Returns Poll::Ready(Ok(())) when the service is able to process requests.

fn call(&mut self, req: Operation<ResponseHandler, RetryPolicy>) -> Self::Future

Process the request and return the response asynchronously.