com.google.common.util.concurrent

Class Futures.MappingCheckedFuture<V,X extends java.lang.Exception>

java.lang.Object

com.google.common.collect.ForwardingObject

com.google.common.util.concurrent.ForwardingFuture<V>

com.google.common.util.concurrent.ForwardingListenableFuture<V>

com.google.common.util.concurrent.ForwardingListenableFuture.SimpleForwardingListenableFuture<V>

com.google.common.util.concurrent.AbstractCheckedFuture<V,X>

com.google.common.util.concurrent.Futures.MappingCheckedFuture<V,X>

All Implemented Interfaces:

CheckedFuture<V,X>, ListenableFuture<V>, java.util.concurrent.Future<V>

Enclosing class:

Futures

private static class Futures.MappingCheckedFuture<V,X extends java.lang.Exception>
extends AbstractCheckedFuture<V,X>

A checked future that uses a function to map from exceptions to the appropriate checked type.

Nested Class Summary

Nested classes/interfaces inherited from class com.google.common.util.concurrent.ForwardingListenableFuture

ForwardingListenableFuture.SimpleForwardingListenableFuture<V>

Nested classes/interfaces inherited from class com.google.common.util.concurrent.ForwardingFuture

ForwardingFuture.SimpleForwardingFuture<V>

Field Summary

Fields

Modifier and Type	Field and Description
(package private) Function<? super java.lang.Exception,X>	mapper

Constructor Summary

Constructors

Constructor and Description
MappingCheckedFuture(ListenableFuture<V> delegate, Function<? super java.lang.Exception,X> mapper)

Method Summary

Modifier and Type	Method and Description
protected X	mapException(java.lang.Exception e) Translates from an InterruptedException, CancellationException or ExecutionException thrown by get to an exception of type X to be thrown by checkedGet.

Methods inherited from class com.google.common.util.concurrent.AbstractCheckedFuture

checkedGet, checkedGet

Methods inherited from class com.google.common.util.concurrent.ForwardingListenableFuture.SimpleForwardingListenableFuture

delegate

Methods inherited from class com.google.common.util.concurrent.ForwardingListenableFuture

addListener

Methods inherited from class com.google.common.util.concurrent.ForwardingFuture

cancel, get, get, isCancelled, isDone

Methods inherited from class com.google.common.collect.ForwardingObject

toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.google.common.util.concurrent.ListenableFuture

addListener

Methods inherited from interface java.util.concurrent.Future

cancel, get, get, isCancelled, isDone

Field Detail

mapper

final Function<? super java.lang.Exception,X extends java.lang.Exception> mapper

Constructor Detail

MappingCheckedFuture

MappingCheckedFuture(ListenableFuture<V> delegate,
                     Function<? super java.lang.Exception,X> mapper)

Method Detail

mapException

protected X mapException(java.lang.Exception e)

Description copied from class: AbstractCheckedFuture

Translates from an InterruptedException, CancellationException or ExecutionException thrown by get to an exception of type X to be thrown by checkedGet. Subclasses must implement this method.

If e is an InterruptedException, the calling checkedGet method has already restored the interrupt after catching the exception. If an implementation of AbstractCheckedFuture.mapException(Exception) wishes to swallow the interrupt, it can do so by calling Thread.interrupted().

Subclasses may choose to throw, rather than return, a subclass of RuntimeException to allow creating a CheckedFuture that throws both checked and unchecked exceptions.

Specified by:

mapException in class AbstractCheckedFuture<V,X extends java.lang.Exception>