ListCollectionsFlow

class ListCollectionsFlow<T : Any>(wrapped: ListCollectionsPublisher<T>) : Flow<T>

Flow implementation for list collection operations.

The type of the result.

Constructors

constructor(wrapped: ListCollectionsPublisher<T>)

Sets the number of documents to return per batch.

open suspend override fun collect(collector: FlowCollector<T>)

fun comment(comment: BsonValue?): ListCollectionsFlow<T>

Sets the comment for this operation. A null value means no comment is set.

Sets the query filter to apply to the returned database names.

fun maxTime(maxTime: Long, timeUnit: TimeUnit = TimeUnit.MILLISECONDS): ListCollectionsFlow<T>

Sets the maximum execution time on the server for this operation.

@Alpha(value = [Reason.CLIENT])

fun timeoutMode(timeoutMode: TimeoutMode): ListCollectionsFlow<T>

Sets the timeoutMode for the cursor.