public interface MappedReactiveResultSet<EntityT> extends org.reactivestreams.Publisher<EntityT>, ReactiveQueryMetadata
Publisher of mapped entities returned by DAO methods. In other words, this interface is
the equivalent of ReactiveResultSet for mapped entities.
By default, all implementations returned by the driver are cold, unicast, single-subscriber only publishers. In other words, they do not support multiple subscriptions; consider caching the results produced by such publishers if you need to consume them by more than one downstream subscriber.
Also, note that mapped reactive result sets may emit items to their subscribers on an internal
driver IO thread. Subscriber implementors are encouraged to abide by Reactive Streams
Specification rule 2.2 and avoid performing heavy computations or blocking calls inside
onNext calls, as doing so could slow down
the driver and impact performance. Instead, they should asynchronously dispatch received signals
to their processing logic.
This type is located in a dse package for historical reasons; reactive result sets
work with both Cassandra and DSE.
ReactiveResultSetgetColumnDefinitions, getExecutionInfos, wasAppliedCopyright © 2017–2021. All rights reserved.