Interface ReactiveUpsertByIdOperation.TerminatingUpsertById<T>

All Superinterfaces:
OneAndAllEntityReactive<T>
All Known Subinterfaces:
ReactiveUpsertByIdOperation.ReactiveUpsertById<T>, ReactiveUpsertByIdOperation.UpsertByIdInCollection<T>, ReactiveUpsertByIdOperation.UpsertByIdInScope<T>, ReactiveUpsertByIdOperation.UpsertByIdWithDurability<T>, ReactiveUpsertByIdOperation.UpsertByIdWithExpiry<T>, ReactiveUpsertByIdOperation.UpsertByIdWithOptions<T>
Enclosing interface:
ReactiveUpsertByIdOperation

public static interface ReactiveUpsertByIdOperation.TerminatingUpsertById<T> extends OneAndAllEntityReactive<T>
Terminating operations invoking the actual execution.
  • Method Summary

    Modifier and Type
    Method
    Description
    reactor.core.publisher.Flux<? extends T>
    all(Collection<? extends T> objects)
    Insert a collection of entities.
    reactor.core.publisher.Mono<T>
    one(T object)
    Upsert one entity.
  • Method Details

    • one

      reactor.core.publisher.Mono<T> one(T object)
      Upsert one entity.
      Specified by:
      one in interface OneAndAllEntityReactive<T>
      Returns:
      Upserted entity.
    • all

      reactor.core.publisher.Flux<? extends T> all(Collection<? extends T> objects)
      Insert a collection of entities.
      Specified by:
      all in interface OneAndAllEntityReactive<T>
      Returns:
      Inserted entities