- protected <D extends Datastore, X extends WriteTransaction, W, E extends Exception> FluentFuture<? extends Object>
- callWithNewTransactionAndSubmit(
- final Class<D> datastoreType, final Supplier<X> txSupplier, final BiFunction<Class<D>, X, W> txWrapper,
- final InterruptibleCheckedConsumer<W, E> txConsumer, final BiFunction<X, W, FluentFuture<?>> txSubmitter) {
- return applyWithNewTransactionAndSubmit(datastoreType, txSupplier, txWrapper, tx -> {
+ protected <D extends Datastore, X extends WriteTransaction, W, E extends Exception>
+ FluentFuture<? extends Object> callWithNewTransactionAndSubmit(final D datastore, final Supplier<X> txSupplier,
+ final BiFunction<D, X, W> txWrapper, final InterruptibleCheckedConsumer<W, E> txConsumer,
+ final BiFunction<X, W, FluentFuture<?>> txSubmitter) {
+ return applyWithNewTransactionAndSubmit(datastore, txSupplier, txWrapper, tx -> {