Package io.quarkus.mongodb.panache.common.reactive.runtime

Class CommonReactivePanacheQueryImpl<Entity>

java.lang.Object

io.quarkus.mongodb.panache.common.reactive.runtime.CommonReactivePanacheQueryImpl<Entity>

public class CommonReactivePanacheQueryImpl<Entity>
extends Object

Constructor Summary

Constructors

Constructor	Description
CommonReactivePanacheQueryImpl(io.quarkus.mongodb.reactive.ReactiveMongoCollection<? extends Entity> collection, org.bson.conversions.Bson mongoQuery, org.bson.conversions.Bson sort)

Method Summary

Modifier and Type	Method	Description
io.smallrye.mutiny.Uni<Long>	count()
<T extends Entity> CommonReactivePanacheQueryImpl<T>	firstPage()
<T extends Entity> io.smallrye.mutiny.Uni<T>	firstResult()
<T extends Entity> io.smallrye.mutiny.Uni<Optional<T>>	firstResultOptional()
io.smallrye.mutiny.Uni<Boolean>	hasNextPage()
boolean	hasPreviousPage()
<T extends Entity> io.smallrye.mutiny.Uni<CommonReactivePanacheQueryImpl<T>>	lastPage()
<T extends Entity> io.smallrye.mutiny.Uni<List<T>>	list()
<T extends Entity> CommonReactivePanacheQueryImpl<T>	nextPage()
io.quarkus.panache.common.Page	page()
<T extends Entity> CommonReactivePanacheQueryImpl<T>	page(int pageIndex, int pageSize)
<T extends Entity> CommonReactivePanacheQueryImpl<T>	page(io.quarkus.panache.common.Page page)
io.smallrye.mutiny.Uni<Integer>	pageCount()
<T extends Entity> CommonReactivePanacheQueryImpl<T>	previousPage()
<T> CommonReactivePanacheQueryImpl<T>	project(Class<T> type)
<T extends Entity> CommonReactivePanacheQueryImpl<T>	range(int startIndex, int lastIndex)
<T extends Entity> io.smallrye.mutiny.Uni<T>	singleResult()
<T extends Entity> io.smallrye.mutiny.Uni<Optional<T>>	singleResultOptional()
<T extends Entity> io.smallrye.mutiny.Multi<T>	stream()
<T extends Entity> CommonReactivePanacheQueryImpl<T>	withBatchSize(int batchSize)
<T extends Entity> CommonReactivePanacheQueryImpl<T>	withCollation(com.mongodb.client.model.Collation collation)
<T extends Entity> CommonReactivePanacheQueryImpl<T>	withReadPreference(com.mongodb.ReadPreference readPreference)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

CommonReactivePanacheQueryImpl

public CommonReactivePanacheQueryImpl(io.quarkus.mongodb.reactive.ReactiveMongoCollection<? extends Entity> collection,
 org.bson.conversions.Bson mongoQuery,
 org.bson.conversions.Bson sort)

Method Details

project

public <T> CommonReactivePanacheQueryImpl<T> project(Class<T> type)

page

public <T extends Entity>
CommonReactivePanacheQueryImpl<T> page(io.quarkus.panache.common.Page page)

page

public <T extends Entity>
CommonReactivePanacheQueryImpl<T> page(int pageIndex,
 int pageSize)

nextPage

public <T extends Entity>
CommonReactivePanacheQueryImpl<T> nextPage()

previousPage

public <T extends Entity>
CommonReactivePanacheQueryImpl<T> previousPage()

firstPage

public <T extends Entity>
CommonReactivePanacheQueryImpl<T> firstPage()

lastPage

public <T extends Entity>
io.smallrye.mutiny.Uni<CommonReactivePanacheQueryImpl<T>> lastPage()

hasNextPage

public io.smallrye.mutiny.Uni<Boolean> hasNextPage()

hasPreviousPage

public boolean hasPreviousPage()

pageCount

public io.smallrye.mutiny.Uni<Integer> pageCount()

page

public io.quarkus.panache.common.Page page()

range

public <T extends Entity>
CommonReactivePanacheQueryImpl<T> range(int startIndex,
 int lastIndex)

withCollation

public <T extends Entity>
CommonReactivePanacheQueryImpl<T> withCollation(com.mongodb.client.model.Collation collation)

withReadPreference

public <T extends Entity>
CommonReactivePanacheQueryImpl<T> withReadPreference(com.mongodb.ReadPreference readPreference)

withBatchSize

public <T extends Entity>
CommonReactivePanacheQueryImpl<T> withBatchSize(int batchSize)

count

public io.smallrye.mutiny.Uni<Long> count()

list

public <T extends Entity>
io.smallrye.mutiny.Uni<List<T>> list()

stream

public <T extends Entity>
io.smallrye.mutiny.Multi<T> stream()

firstResult

public <T extends Entity> io.smallrye.mutiny.Uni<T> firstResult()

firstResultOptional

public <T extends Entity>
io.smallrye.mutiny.Uni<Optional<T>> firstResultOptional()

singleResult

public <T extends Entity> io.smallrye.mutiny.Uni<T> singleResult()

singleResultOptional

public <T extends Entity>
io.smallrye.mutiny.Uni<Optional<T>> singleResultOptional()