keyspacesstreams/aws.sdk.kotlin.services.keyspacesstreams.paginators

Package-level declarations

Inherited functions

getStreamPaginated

fun KeyspacesStreamsClient.getStreamPaginated(initialRequest: GetStreamRequest): Flow<GetStreamResponse>

fun KeyspacesStreamsClient.getStreamPaginated(block: GetStreamRequest.Builder.() -> Unit): Flow<GetStreamResponse>

Paginate over GetStreamResponse results.

listStreamsPaginated

fun KeyspacesStreamsClient.listStreamsPaginated(initialRequest: ListStreamsRequest = ListStreamsRequest { }): Flow<ListStreamsResponse>

fun KeyspacesStreamsClient.listStreamsPaginated(block: ListStreamsRequest.Builder.() -> Unit): Flow<ListStreamsResponse>

Paginate over ListStreamsResponse results.

fun Flow<GetStreamResponse>.shards(): Flow<Shard>

This paginator transforms the flow returned by getStreamPaginated to access the nested member Shard

fun Flow<ListStreamsResponse>.streams(): Flow<Stream>

This paginator transforms the flow returned by listStreamsPaginated to access the nested member Stream