mirror of
https://github.com/usatiuk/dhfs.git
synced 2025-10-28 12:37:48 +01:00
Utils: remove VoidFn
This commit is contained in:
@@ -1,6 +1,5 @@
|
|||||||
package com.usatiuk.objects.transaction;
|
package com.usatiuk.objects.transaction;
|
||||||
|
|
||||||
import com.usatiuk.utils.VoidFn;
|
|
||||||
import io.quarkus.logging.Log;
|
import io.quarkus.logging.Log;
|
||||||
|
|
||||||
import java.util.function.Supplier;
|
import java.util.function.Supplier;
|
||||||
@@ -41,9 +40,9 @@ public interface TransactionManager {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
default TransactionHandle runTries(VoidFn fn, int tries, boolean nest) {
|
default TransactionHandle runTries(Runnable fn, int tries, boolean nest) {
|
||||||
if (!nest && current() != null) {
|
if (!nest && current() != null) {
|
||||||
fn.apply();
|
fn.run();
|
||||||
return new TransactionHandle() {
|
return new TransactionHandle() {
|
||||||
@Override
|
@Override
|
||||||
public void onFlush(Runnable runnable) {
|
public void onFlush(Runnable runnable) {
|
||||||
@@ -56,7 +55,7 @@ public interface TransactionManager {
|
|||||||
begin();
|
begin();
|
||||||
boolean commit = false;
|
boolean commit = false;
|
||||||
try {
|
try {
|
||||||
fn.apply();
|
fn.run();
|
||||||
commit = true;
|
commit = true;
|
||||||
var ret = commit();
|
var ret = commit();
|
||||||
return ret;
|
return ret;
|
||||||
@@ -80,11 +79,11 @@ public interface TransactionManager {
|
|||||||
return runTries(supplier, tries, false);
|
return runTries(supplier, tries, false);
|
||||||
}
|
}
|
||||||
|
|
||||||
default TransactionHandle runTries(VoidFn fn, int tries) {
|
default TransactionHandle runTries(Runnable fn, int tries) {
|
||||||
return runTries(fn, tries, false);
|
return runTries(fn, tries, false);
|
||||||
}
|
}
|
||||||
|
|
||||||
default TransactionHandle run(VoidFn fn, boolean nest) {
|
default TransactionHandle run(Runnable fn, boolean nest) {
|
||||||
return runTries(fn, 10, nest);
|
return runTries(fn, 10, nest);
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -92,7 +91,7 @@ public interface TransactionManager {
|
|||||||
return runTries(supplier, 10, nest);
|
return runTries(supplier, 10, nest);
|
||||||
}
|
}
|
||||||
|
|
||||||
default TransactionHandle run(VoidFn fn) {
|
default TransactionHandle run(Runnable fn) {
|
||||||
return run(fn, false);
|
return run(fn, false);
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -100,7 +99,7 @@ public interface TransactionManager {
|
|||||||
return run(supplier, false);
|
return run(supplier, false);
|
||||||
}
|
}
|
||||||
|
|
||||||
default void executeTx(VoidFn fn) {
|
default void executeTx(Runnable fn) {
|
||||||
run(fn, false);
|
run(fn, false);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -1,7 +0,0 @@
|
|||||||
package com.usatiuk.utils;
|
|
||||||
|
|
||||||
@FunctionalInterface
|
|
||||||
public interface VoidFn {
|
|
||||||
void apply();
|
|
||||||
}
|
|
||||||
|
|
||||||
@@ -1,7 +0,0 @@
|
|||||||
package com.usatiuk.utils;
|
|
||||||
|
|
||||||
@FunctionalInterface
|
|
||||||
public interface VoidFnThrows {
|
|
||||||
void apply() throws Throwable;
|
|
||||||
}
|
|
||||||
|
|
||||||
Reference in New Issue
Block a user