net.sf.asyncobjects.util
Class CloseableWrapper.InvalidatingWhen<I,R>

java.lang.Object
  net.sf.asyncobjects.When<I,R>
      net.sf.asyncobjects.util.CloseableWrapper.InvalidatingWhen<I,R>

Type Parameters:

I - Input type

R - Result type

All Implemented Interfaces:

ExplicitSharing

Enclosing class:

CloseableWrapper<FacetType extends ACloseable,WrappedType extends ACloseable>

protected abstract class CloseableWrapper.InvalidatingWhen<I,R>
extends When<I,R>

When that invalidates the stream in case of exception

Nested Class Summary

Nested classes/interfaces inherited from class net.sf.asyncobjects.When

When.InternalArgumentListener, When.InternalBodyPromiseResolver, When.InternalFinallyListenerAfterFault, When.InternalFinallyListenerAfterSuccess, When.InternalResultPromiseResolver

Constructor Summary

CloseableWrapper.InvalidatingWhen(Promise<I> p)
A constructor from superclass

Method Summary

protected Promise<? extends R>

smashed(Throwable problem) In addition to base class functionaity, the stream is marked as invalid.

Methods inherited from class net.sf.asyncobjects.When

bodySmashed, finallyDo, promise, resolved

Methods inherited from class java.lang.Object

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

Constructor Detail

CloseableWrapper.InvalidatingWhen

public CloseableWrapper.InvalidatingWhen(Promise<I> p)

A constructor from superclass

Parameters:

p - a promise

Method Detail

smashed

protected final Promise<? extends R> smashed(Throwable problem)
                                      throws Throwable

In addition to base class functionaity, the stream is marked as invalid.

Overrides:

smashed in class When<I,R>

Parameters:

problem - a problem that broken a promise.

Returns:

a value becomes curren result of promise

Throws:

Throwable - if there is a problem

See Also:

When.smashed(java.lang.Throwable)