*/
public abstract class OFRpcTaskUtil {
protected static final Logger LOG = LoggerFactory.getLogger(OFRpcTaskUtil.class);
- /**
- * @param taskContext
- * @param isBarrier
- * @param cookie
- * @return rpcResult of given type, containing wrapped errors of barrier sending (if any) or success
- */
private OFRpcTaskUtil() {
//hiding implicit constructor
}
ListenableFuture<RpcResult<T>> chainResult = originalResult;
if (MoreObjects.firstNonNull(task.isBarrier(), Boolean.FALSE)) {
- chainResult = Futures.transform(originalResult, new AsyncFunction<RpcResult<T>, RpcResult<T>>() {
+ chainResult = Futures.transformAsync(originalResult, new AsyncFunction<RpcResult<T>, RpcResult<T>>() {
@Override
public ListenableFuture<RpcResult<T>> apply(final RpcResult<T> input) throws Exception {