Package org.springframework.data.cassandra.core

Interface ReactiveSelectOperation.TerminatingSelect<T>

All Known Subinterfaces:
ReactiveSelectOperation.ReactiveSelect<T>, ReactiveSelectOperation.SelectWithProjection<T>, ReactiveSelectOperation.SelectWithQuery<T>, ReactiveSelectOperation.SelectWithTable<T>
Enclosing interface:
ReactiveSelectOperation
public static interface ReactiveSelectOperation.TerminatingSelect<T>
Trigger SELECT execution by calling one of the terminating methods.

  • Method Summary

    Modifier and Type
    Method
    Description
    reactor.core.publisher.Flux<T>
    all()
    Get all matching elements.
    reactor.core.publisher.Mono<Long>
    count()
    Get the number of matching elements.
    reactor.core.publisher.Mono<Boolean>
    exists()
    Check for the presence of matching elements.
    reactor.core.publisher.Mono<T>
    first()
    Get the first result or no result.
    reactor.core.publisher.Mono<T>
    one()
    Get exactly zero or one result.

  • Method Details

    • count

      reactor.core.publisher.Mono<Long> count()
      Get the number of matching elements.
      Returns:
      a Mono emitting the total number of matching elements; never null.
      See Also:
      • Mono

    • exists

      reactor.core.publisher.Mono<Boolean> exists()
      Check for the presence of matching elements.
      Returns:
      a Mono emitting true if at least one matching element exists; never null.
      See Also:
      • Mono

    • first

      reactor.core.publisher.Mono<T> first()
      Get the first result or no result.
      Returns:
      the first result or Mono.empty() if no match found; never null.
      See Also:
      • Mono

    • one

      reactor.core.publisher.Mono<T> one()
      Get exactly zero or one result.
      Returns:
      exactly one result or Mono.empty() if no match found; never null.
      Throws:
      IncorrectResultSizeDataAccessException - if more than one match found.
      See Also:
      • Mono

    • all

      reactor.core.publisher.Flux<T> all()
      Get all matching elements.
      Returns:
      all matching elements; never null.
      See Also:
      • Flux