Struct HeaderCursorContinuation 

pub struct HeaderCursorContinuation<'cursor, 'endpoint, 'session, 'request, 'policy> { /* private fields */ }

Cleanup-owning cursor inseparable from its original prepared request.

Continuations expose execution only; another request cannot be attached.

use cloud_sdk::operation::PreparedRequest;
use cloud_sdk::pagination::HeaderCursorContinuation;

fn rebind(
    continuation: HeaderCursorContinuation<'_, '_, '_, '_, '_>,
    replacement: PreparedRequest<'_>,
) {
    continuation.bind(replacement);
}

Implementations

impl<'cursor, 'endpoint, 'session, 'request, 'policy> HeaderCursorContinuation<'cursor, 'endpoint, 'session, 'request, 'policy>

pub async fn execute_async<'response, 'next, T>( &self, transport: &T, response_storage: &'response mut [u8], response_header_storage: &'response mut [u8], decimal_scratch: &mut [u8], transfer_scratch: &mut [u8], cursor_destination: &'next mut [u8], limits: PaginationLimits, ) -> Result<HeaderCursorPage<'response, 'next, 'endpoint, 'session, 'request, 'policy>, HeaderCursorExecutionError<T::Error>>

where T: AsyncAuthenticatedTransport + BoundTransport,

Executes the next executor-neutral async request with retained context.

impl<'cursor, 'endpoint, 'session, 'request, 'policy> HeaderCursorContinuation<'cursor, 'endpoint, 'session, 'request, 'policy>

pub async fn execute_local_async<'response, 'next, T>( &self, transport: &T, response_storage: &'response mut [u8], response_header_storage: &'response mut [u8], decimal_scratch: &mut [u8], transfer_scratch: &mut [u8], cursor_destination: &'next mut [u8], limits: PaginationLimits, ) -> Result<HeaderCursorPage<'response, 'next, 'endpoint, 'session, 'request, 'policy>, HeaderCursorExecutionError<T::Error>>

where T: LocalAsyncAuthenticatedTransport + BoundTransport,

Executes the next local async request with retained context.

impl<'cursor, 'endpoint, 'session, 'request, 'policy> HeaderCursorContinuation<'cursor, 'endpoint, 'session, 'request, 'policy>

pub const fn operation_id(&self) -> OperationId

Returns the provider operation that produced this continuation.

pub fn observe_history( &self, history: &mut CursorHistory<'_>, digest: CursorDigest, ) -> Result<(), PaginationError>

Checks and transactionally records the exact cursor in caller history.

pub fn execute_blocking<'response, 'next, T>( &self, transport: &T, response_storage: &'response mut [u8], response_header_storage: &'response mut [u8], decimal_scratch: &mut [u8], transfer_scratch: &mut [u8], cursor_destination: &'next mut [u8], limits: PaginationLimits, ) -> Result<HeaderCursorPage<'response, 'next, 'endpoint, 'session, 'request, 'policy>, HeaderCursorExecutionError<T::Error>>

where T: BlockingAuthenticatedTransport + BoundTransport,

Executes the next blocking request using the retained request context.

Trait Implementations

impl Debug for HeaderCursorContinuation<'_, '_, '_, '_, '_>

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

Formats the value using the given formatter.