class DistinctFlow<T : Any>(wrapped: DistinctPublisher<T>) : Flow<T>

Flow implementation for distinct operations.



The type of the result.

See also


Link copied to clipboard
constructor(wrapped: DistinctPublisher<T>)


Link copied to clipboard
fun batchSize(batchSize: Int): DistinctFlow<T>

Sets the number of documents to return per batch.

Link copied to clipboard
fun collation(collation: Collation?): DistinctFlow<T>

Sets the collation options

Link copied to clipboard
open suspend override fun collect(collector: FlowCollector<T>)
Link copied to clipboard
fun comment(comment: String?): DistinctFlow<T>
fun comment(comment: BsonValue?): DistinctFlow<T>

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

Link copied to clipboard
fun filter(filter: Bson?): DistinctFlow<T>

Sets the query filter to apply to the query.

Link copied to clipboard
fun maxTime(maxTime: Long, timeUnit: TimeUnit = TimeUnit.MILLISECONDS): DistinctFlow<T>

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