Simplified ReactiveSagaInstanceRepositoryJdbc.find

eventuate-tram · Jul 27, 2021 · 536389b · 536389b
1 parent 8e1fd3f
commit 536389b
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/...va/io/eventuate/tram/sagas/reactive/orchestration/ReactiveSagaInstanceRepositoryJdbc.java b/...va/io/eventuate/tram/sagas/reactive/orchestration/ReactiveSagaInstanceRepositoryJdbc.java
@@ -87,15 +87,13 @@ public Mono<SagaInstance> find(String sagaType, String sagaId) {
             (row, rowMetadata) -> new DestinationAndResource(row.get("destination").toString(), row.get("resource").toString()),
             sagaType, sagaId);
 
-    Mono<List<SagaInstance>> result = destinationAndResources.collectList().flatMap(dar ->
+    return destinationAndResources.collectList().flatMap(dar ->
       eventuateJdbcStatementExecutor.queryForList(sagaInstanceRepositorySql.getSelectFromSagaInstanceSql(),
               (row, rowMetadata) ->
                 new SagaInstance(sagaType, sagaId, row.get("state_name").toString(),
                         row.get("last_request_id").toString(),
                         new SerializedSagaData(row.get("saga_data_type").toString(), row.get("saga_data_json").toString()), new HashSet<>(dar)),
-              sagaType, sagaId).collectList());
-
-    return result.flatMapMany(Flux::fromIterable).single();
+              sagaType, sagaId).single());
   }