Итак, я использую Spring Data Cassandra и RxJava, я ищу способ использовать RxJava Observable с пользовательским построением запросов (абстракция find..by слишком сложна для использования в моем случае), и я планировал использовать QueryDSL (метод findAll (Predicate), но он не включает Async: /)
Пока что я лучше всего использую AsyncCassandraTemplate для создания запроса и возвращаю его как ListenableFuture, чтобы его можно было сопоставить с Observable и использовать с Observable RxJava. Есть ли другой способ?
