Skip to content

Commit

Permalink
WIP
Browse files Browse the repository at this point in the history
  • Loading branch information
anton-vinogradov committed Jun 28, 2023
1 parent 4e29718 commit ddb4a4a
Showing 1 changed file with 5 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -825,11 +825,11 @@ private <K, V> IgniteInternalFuture mvccPutAllAsync0(
return transform ? EnlistOperation.TRANSFORM : EnlistOperation.UPSERT;
}

@Override public boolean hasNextX() throws IgniteCheckedException {
@Override public boolean hasNextX() {
return it.hasNext();
}

@Override public IgniteBiTuple<KeyCacheObject, Object> nextX() throws IgniteCheckedException {
@Override public IgniteBiTuple<KeyCacheObject, Object> nextX() {
Map.Entry<KeyCacheObject, Object> next = it.next();

return new IgniteBiTuple<>(next.getKey(), next.getValue());
Expand Down Expand Up @@ -2021,11 +2021,11 @@ private <K, V> IgniteInternalFuture<GridCacheReturn> mvccRemoveAllAsync0(
return EnlistOperation.DELETE;
}

@Override public boolean hasNextX() throws IgniteCheckedException {
@Override public boolean hasNextX() {
return it.hasNext();
}

@Override public KeyCacheObject nextX() throws IgniteCheckedException {
@Override public KeyCacheObject nextX() {
return it.next();
}
}, retval, filter, remainingTime());
Expand Down Expand Up @@ -5077,9 +5077,8 @@ protected abstract class FinishClosure<T> implements IgniteBiClosure<T, Exceptio
/**
* @param t Argument.
* @return Result.
* @throws IgniteCheckedException If failed.
*/
abstract T finish(T t) throws IgniteCheckedException;
abstract T finish(T t);
}

/** */
Expand Down

0 comments on commit ddb4a4a

Please sign in to comment.