Package akka.javasdk.client
Interface ViewStreamMethodRef<R>
- Type Parameters:
R- The type of entries in the view
- All Superinterfaces:
ComponentStreamMethodRef<R>
Zero argument component call representation, query is not executed until stream is materialized.
Cannot be deferred.
Not for user extension
-
Method Summary
Modifier and TypeMethodDescriptionakka.stream.javadsl.Source<EntryWithMetadata<R>, akka.NotUsed> akka.stream.javadsl.Source<EntryWithMetadata<R>, akka.NotUsed> entriesSource(Optional<Instant> updatedAfter) akka.stream.javadsl.Source<R, akka.NotUsed> source()
-
Method Details
-
source
akka.stream.javadsl.Source<R,akka.NotUsed> source()- Specified by:
sourcein interfaceComponentStreamMethodRef<R>- Returns:
- A stream of view entries.
-
entriesSource
akka.stream.javadsl.Source<EntryWithMetadata<R>,akka.NotUsed> entriesSource()- Returns:
- A stream of view entries, including metadata.
-
entriesSource
akka.stream.javadsl.Source<EntryWithMetadata<R>,akka.NotUsed> entriesSource(Optional<Instant> updatedAfter) - Parameters:
updatedAfter- If not empty, only return rows updated later than this time.- Returns:
- A stream of view entries, including metadata.
-