This commit is contained in:
Andrea Cavalli 2021-09-24 02:02:10 +02:00
parent 29cd7e7820
commit 9a624ca3e2

View File

@ -23,6 +23,7 @@ import io.net5.buffer.api.Drop;
import io.net5.buffer.api.Owned;
import io.net5.buffer.api.Send;
import io.net5.buffer.api.internal.ResourceSupport;
import it.cavallium.dbengine.database.collections.DatabaseSingle;
import java.util.Objects;
public final class DataBlock extends ResourceSupport<DataBlock, DataBlock> {
@ -118,7 +119,11 @@ public final class DataBlock extends ResourceSupport<DataBlock, DataBlock> {
private final Drop<DataBlock> delegate;
public CloseOnDrop(Drop<DataBlock> drop) {
this.delegate = drop;
if (drop instanceof CloseOnDrop closeOnDrop) {
this.delegate = closeOnDrop.delegate;
} else {
this.delegate = drop;
}
}
@Override