import java.sql.SQLException;
import java.util.Collection;
import java.util.List;
+import java.util.Objects;
import io.reactivex.rxjava3.core.Observable;
import io.reactivex.rxjava3.subjects.PublishSubject;
"""
).formatted(TABLE_IDENTITY);
try (final var statement = connection.prepareStatement(sql)) {
- return Utils.executeQueryForStream(statement, this::getIdentityInfoFromResultSet).toList();
+ return Utils.executeQueryForStream(statement, this::getIdentityInfoFromResultSet)
+ .filter(Objects::nonNull)
+ .toList();
}
} catch (SQLException e) {
throw new RuntimeException("Failed read from identity store", e);
try (final var statement = connection.prepareStatement(sql)) {
statement.setInt(1, accountIdType);
records = Utils.executeQueryForStream(statement,
- res -> new Pair<>(getKeyFromResultSet(res), getSessionRecordFromResultSet(res))).toList();
+ res -> new Pair<>(getKeyFromResultSet(res), getSessionRecordFromResultSet(res)))
+ .filter(Objects::nonNull)
+ .toList();
}
for (final var record : records) {
record.second().archiveCurrentState();
statement.setInt(1, accountIdType);
statement.setBytes(2, serviceId.toByteArray());
records = Utils.executeQueryForStream(statement,
- res -> new Pair<>(getKeyFromResultSet(res), getSessionRecordFromResultSet(res))).toList();
+ res -> new Pair<>(getKeyFromResultSet(res), getSessionRecordFromResultSet(res)))
+ .filter(Objects::nonNull)
+ .toList();
}
for (final var record : records) {
record.second().archiveCurrentState();