diff --git a/src/main/java/it/cavallium/dbengine/database/disk/LLLocalKeyValueDatabase.java b/src/main/java/it/cavallium/dbengine/database/disk/LLLocalKeyValueDatabase.java
index 69c88be..ac237d3 100644
--- a/src/main/java/it/cavallium/dbengine/database/disk/LLLocalKeyValueDatabase.java
+++ b/src/main/java/it/cavallium/dbengine/database/disk/LLLocalKeyValueDatabase.java
@@ -1003,29 +1003,26 @@ public class LLLocalKeyValueDatabase implements LLKeyValueDatabase {
 
 	@Override
 	public Mono<LLLocalDictionary> getDictionary(byte[] columnName, UpdateMode updateMode) {
-		return Mono
-				.fromCallable(() -> {
-					var closeReadLock = closeLock.readLock();
-					try {
-						ensureOpen();
-						var cfh = getCfh(columnName);
-						ensureOwned(cfh);
-						return new LLLocalDictionary(
-								allocator,
-								getRocksDBColumn(db, cfh),
-								name,
-								ColumnUtils.toString(columnName),
-								dbWScheduler,
-								dbRScheduler,
-								this::getSnapshotLambda,
-								updateMode,
-								databaseOptions
-						);
-					} finally {
-						closeLock.unlockRead(closeReadLock);
-					}
-				})
-				.subscribeOn(dbRScheduler);
+		return Mono.fromCallable(() -> {
+			var closeReadLock = closeLock.readLock();
+			try {
+				ensureOpen();
+				var cfh = getCfh(columnName);
+				ensureOwned(cfh);
+				return new LLLocalDictionary(allocator,
+						getRocksDBColumn(db, cfh),
+						name,
+						ColumnUtils.toString(columnName),
+						dbWScheduler,
+						dbRScheduler,
+						this::getSnapshotLambda,
+						updateMode,
+						databaseOptions
+				);
+			} finally {
+				closeLock.unlockRead(closeReadLock);
+			}
+		}).subscribeOn(dbRScheduler);
 	}
 
 	public RocksDBColumn getRocksDBColumn(byte[] columnName) {