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

Class JavaReactiveMongoOperations

java.lang.Object

io.quarkus.mongodb.panache.common.reactive.runtime.ReactiveMongoOperations<ReactivePanacheQuery<?>,io.quarkus.mongodb.panache.common.reactive.ReactivePanacheUpdate>

io.quarkus.mongodb.panache.reactive.runtime.JavaReactiveMongoOperations

public class JavaReactiveMongoOperations
extends io.quarkus.mongodb.panache.common.reactive.runtime.ReactiveMongoOperations<ReactivePanacheQuery<?>,io.quarkus.mongodb.panache.common.reactive.ReactivePanacheUpdate>

Field Summary

Fields

Modifier and Type	Field	Description
static final JavaReactiveMongoOperations	INSTANCE

Fields inherited from class io.quarkus.mongodb.panache.common.reactive.runtime.ReactiveMongoOperations

ID

Constructor Summary

Constructors

Constructor	Description
JavaReactiveMongoOperations()

Method Summary

Modifier and Type	Method	Description
protected ReactivePanacheQuery<?>	createQuery(io.quarkus.mongodb.reactive.ReactiveMongoCollection collection, org.bson.conversions.Bson query, org.bson.conversions.Bson sortDoc)
protected io.quarkus.mongodb.panache.common.reactive.ReactivePanacheUpdate	createUpdate(io.quarkus.mongodb.reactive.ReactiveMongoCollection<?> collection, Class<?> entityClass, org.bson.conversions.Bson docUpdate)
protected io.smallrye.mutiny.Uni<? extends List<?>>	list(ReactivePanacheQuery<?> query)
protected io.smallrye.mutiny.Multi<?>	stream(ReactivePanacheQuery<?> query)

Methods inherited from class io.quarkus.mongodb.panache.common.reactive.runtime.ReactiveMongoOperations

bindFilter, bindFilter, count, count, count, count, count, delete, delete, delete, delete, delete, deleteAll, deleteById, find, find, find, find, find, find, find, find, find, findAll, findAll, findById, findByIdOptional, findByIds, implementationInjectionMissing, list, list, list, list, list, list, list, list, listAll, listAll, mongoCollection, mongoDatabase, nullUni, persist, persist, persist, persist, persistOrUpdate, persistOrUpdate, persistOrUpdate, persistOrUpdate, stream, stream, stream, stream, stream, stream, stream, stream, streamAll, streamAll, update, update, update, update, update, update, update, update

Methods inherited from class java.lang.Object

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

Field Details

INSTANCE

public static final JavaReactiveMongoOperations INSTANCE

Constructor Details

JavaReactiveMongoOperations

public JavaReactiveMongoOperations()

Method Details

createQuery

protected ReactivePanacheQuery<?> createQuery(io.quarkus.mongodb.reactive.ReactiveMongoCollection collection,
 org.bson.conversions.Bson query,
 org.bson.conversions.Bson sortDoc)

Specified by:

createQuery in class io.quarkus.mongodb.panache.common.reactive.runtime.ReactiveMongoOperations<ReactivePanacheQuery<?>,io.quarkus.mongodb.panache.common.reactive.ReactivePanacheUpdate>

createUpdate

protected io.quarkus.mongodb.panache.common.reactive.ReactivePanacheUpdate createUpdate(io.quarkus.mongodb.reactive.ReactiveMongoCollection<?> collection,
 Class<?> entityClass,
 org.bson.conversions.Bson docUpdate)

Specified by:

createUpdate in class io.quarkus.mongodb.panache.common.reactive.runtime.ReactiveMongoOperations<ReactivePanacheQuery<?>,io.quarkus.mongodb.panache.common.reactive.ReactivePanacheUpdate>

list

protected io.smallrye.mutiny.Uni<? extends List<?>> list(ReactivePanacheQuery<?> query)

Specified by:

list in class io.quarkus.mongodb.panache.common.reactive.runtime.ReactiveMongoOperations<ReactivePanacheQuery<?>,io.quarkus.mongodb.panache.common.reactive.ReactivePanacheUpdate>

stream

protected io.smallrye.mutiny.Multi<?> stream(ReactivePanacheQuery<?> query)

Specified by:

stream in class io.quarkus.mongodb.panache.common.reactive.runtime.ReactiveMongoOperations<ReactivePanacheQuery<?>,io.quarkus.mongodb.panache.common.reactive.ReactivePanacheUpdate>