Как вернуть свои собственные фьючерсы в Java?

Question

В Java 8 я пишу метод DAO, который вызывает метод, который возвращает ListenableFuture (в этом случае это асинхронный запрос Cassandra, который возвращает ResultSetFuture).

Однако я зациклился на том, как я должен вернуть Будущее вызывающему методу DAO. Я не могу просто вернуть ResultSetFuture, потому что это будущее возвращает ResultSet. Я хочу обработать ResultSet и вернуть другой объект. Например:

public ListenableFuture<ThingObj> queryForThingAsync(String thingId) { 
    ListenableFuture<ResultSet> rsFuture = db.getSession().executeAsync(QueryBuilder.select().all().from("thingSchema","Thing").where(eq("thingId",thingId))); 
    // Now what? How do I create a ListenableFuture<ThingObj> given a ListenableFuture<ResultSet> and a method that can convert a ResultSet into a ThingObj? 
} 

Answer 1

Так как кажется вы используете гуавы-х ListenableFuture, самым простым решением является transform метод из Futures:

Возвращает новый ListenableFuture, результатом которого является продуктом применения данной функции к результату данного Будущего.

Есть несколько способов, чтобы использовать его, но так как вы на Java 8, самый простой, вероятно, со ссылкой метод:

public ListenableFuture<ThingObj> queryForThingAsync(String thingId) { 
    ListenableFuture<ResultSet> rsFuture = db.getSession().executeAsync(QueryBuilder.select().all().from("thingSchema","Thing").where(eq("thingId",thingId))); 
    return Futures.transform(rsFuture, Utils::convertToThingObj); 
}