diff --git a/storage/src/main/java/tech/pegasys/teku/storage/server/rocksdb/RocksDbInstance.java b/storage/src/main/java/tech/pegasys/teku/storage/server/rocksdb/RocksDbInstance.java index b8bc2082840..f9a1c11675b 100644 --- a/storage/src/main/java/tech/pegasys/teku/storage/server/rocksdb/RocksDbInstance.java +++ b/storage/src/main/java/tech/pegasys/teku/storage/server/rocksdb/RocksDbInstance.java @@ -158,7 +158,9 @@ public Stream streamKeys(final KvStoreColumn column) { return createKeyStream( column, iter -> { - if (iter.isValid()) iter.seekToFirst(); + if (iter.isValid()) { + iter.seekToFirst(); + } }); } @@ -169,7 +171,9 @@ public Stream> streamRaw(final KvStoreColumn col return createStreamRaw( column, iter -> { - if (iter.isValid()) iter.seekToFirst(); + if (iter.isValid()) { + iter.seekToFirst(); + } }, key -> true) .map(entry -> ColumnEntry.create(Bytes.wrap(entry.getKey()), Bytes.wrap(entry.getValue()))); @@ -182,7 +186,9 @@ public Stream streamKeysRaw(final KvStoreColumn column) { return createStreamKeyRaw( column, iter -> { - if (iter.isValid()) iter.seekToFirst(); + if (iter.isValid()) { + iter.seekToFirst(); + } }, key -> true) .map(Bytes::wrap); @@ -208,7 +214,9 @@ public , V> Stream> stream( return createStream( column, iter -> { - if (iter.isValid()) iter.seek(column.getKeySerializer().serialize(from)); + if (iter.isValid()) { + iter.seek(column.getKeySerializer().serialize(from)); + } }, key -> key.compareTo(to) <= 0); } @@ -221,7 +229,9 @@ public , V> Stream streamKeys( return createKeyStream( column, iter -> { - if (iter.isValid()) iter.seek(column.getKeySerializer().serialize(from)); + if (iter.isValid()) { + iter.seek(column.getKeySerializer().serialize(from)); + } }, key -> key.compareTo(to) <= 0); }