Package one.microstream.storage.types

Class DisruptionCollectorExecuting.WrapperThrowingProcedure<E>

java.lang.Object

one.microstream.storage.types.DisruptionCollector.Default

one.microstream.storage.types.DisruptionCollectorExecuting.WrapperThrowingProcedure<E>

All Implemented Interfaces:

DisruptionCollector, DisruptionCollectorExecuting<E>

Enclosing interface:

DisruptionCollectorExecuting<E>

public static class DisruptionCollectorExecuting.WrapperThrowingProcedure<E>
extends DisruptionCollector.Default
implements DisruptionCollectorExecuting<E>

Nested Class Summary

Nested classes/interfaces inherited from interface one.microstream.storage.types.DisruptionCollector

DisruptionCollector.Default

Nested classes/interfaces inherited from interface one.microstream.storage.types.DisruptionCollectorExecuting

DisruptionCollectorExecuting.WrapperThrowingProcedure<E>

Constructor Summary

Constructors

Constructor	Description
WrapperThrowingProcedure(ThrowingProcedure<? super E,?> logic, Supplier<? extends XCollection<Throwable>> collectionSupplier, XCollection<Throwable> disruptions)

Method Summary

Modifier and Type	Method	Description
void	executeOn(E element)

Methods inherited from class one.microstream.storage.types.DisruptionCollector.Default

collectDisruption, hasDisruptions, reset, toArray, toMultiCauseException, yield

Methods inherited from class java.lang.Object

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

Methods inherited from interface one.microstream.storage.types.DisruptionCollector

collectDisruption, execute, execute, execute, execute, execute, hasDisruptions, reset, toArray, toMultiCauseException, toMultiCauseException, yield, yield

Constructor Details

WrapperThrowingProcedure

public WrapperThrowingProcedure(ThrowingProcedure<? super E,?> logic, Supplier<? extends XCollection<Throwable>> collectionSupplier, XCollection<Throwable> disruptions)

Method Details

executeOn

public void executeOn(E element)

Specified by:

executeOn in interface DisruptionCollectorExecuting<E>