com.mongodb.reactivestreams.client

Interface DistinctPublisher<TResult>

Type Parameters:

TResult - The type of the result.

All Superinterfaces:

org.reactivestreams.Publisher<TResult>

public interface DistinctPublisher<TResult>
extends org.reactivestreams.Publisher<TResult>

Iterable for distinct.

Since:

1.0

Method Summary

Modifier and Type	Method and Description
DistinctPublisher<TResult>	batchSize(int batchSize) Sets the number of documents to return per batch.
DistinctPublisher<TResult>	collation(Collation collation) Sets the collation options
DistinctPublisher<TResult>	filter(Bson filter) Sets the query filter to apply to the query.
org.reactivestreams.Publisher<TResult>	first() Helper to return a publisher limited to the first result.
DistinctPublisher<TResult>	maxTime(long maxTime, TimeUnit timeUnit) Sets the maximum execution time on the server for this operation.

Methods inherited from interface org.reactivestreams.Publisher

subscribe

Method Detail

filter

DistinctPublisher<TResult> filter(Bson filter)

Sets the query filter to apply to the query.

Parameters:

filter - the filter, which may be null.

Returns:

this

MongoDB documentation

Filter

maxTime

DistinctPublisher<TResult> maxTime(long maxTime,
                                   TimeUnit timeUnit)

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

Parameters:

maxTime - the max time

timeUnit - the time unit, which may not be null

Returns:

this

collation

DistinctPublisher<TResult> collation(Collation collation)

Sets the collation options

A null value represents the server default.

Parameters:

collation - the collation options to use

Returns:

this

Since:

1.3

Since server release

3.4

batchSize

DistinctPublisher<TResult> batchSize(int batchSize)

Sets the number of documents to return per batch.

Overrides the Subscription.request(long) value for setting the batch size, allowing for fine grained control over the underlying cursor.

Parameters:

batchSize - the batch size

Returns:

this

Since:

1.8

MongoDB documentation

Batch Size

first

org.reactivestreams.Publisher<TResult> first()

Helper to return a publisher limited to the first result.

Returns:

a Publisher which will contain a single item.

Since:

1.8