Package akka.javasdk.client

Interface ViewStreamMethodRef1<A1,R>

Type Parameters:
A1 - The type of the view input
R - The type of entries in the view
All Superinterfaces:
ComponentStreamMethodRef1<A1,R>
@DoNotInherit public interface ViewStreamMethodRef1<A1,R> extends ComponentStreamMethodRef1<A1,R>
One argument streaming view query representation, the query is not executed until stream is materialized. Cannot be deferred.

Not for user extension

  • Method Details

    • source

      akka.stream.javadsl.Source<R,akka.NotUsed> source(A1 arg)
      Specified by:
      source in interface ComponentStreamMethodRef1<A1,R>
      Returns:
      A stream of view entries.

    • entriesSource

      akka.stream.javadsl.Source<EntryWithMetadata<R>,akka.NotUsed> entriesSource(A1 arg)
      Returns:
      A stream of view entries, including metadata.

    • entriesSource

      akka.stream.javadsl.Source<EntryWithMetadata<R>,akka.NotUsed> entriesSource(A1 arg, Optional<Instant> updatedAfter)
      Parameters:
      arg - Query parameters
      updatedAfter - If not empty, only return rows updated later than this time.
      Returns:
      A stream of view entries, including metadata.