Package | Description |
---|---|
org.mule.runtime.core.api.rx | |
org.mule.runtime.core.api.util | |
org.mule.runtime.core.api.util.concurrent |
Modifier and Type | Method and Description |
---|---|
static <T,R> Function<T,R> |
Exceptions.checkedFunction(CheckedFunction<T,R> checkedFunction)
Adapt a
CheckedFunction to a Function propagating any exceptions thrown by the CheckedFunction using
Exceptions.propagate(Throwable) . |
Modifier and Type | Method and Description |
---|---|
static <T> T |
IOUtils.ifInputStream(Object value,
CheckedFunction<InputStream,T> function) |
static CoreEvent |
StreamingUtils.withCursoredEvent(CoreEvent event,
CheckedFunction<CoreEvent,CoreEvent> f)
Executes the given function
f considering that the given event might have a CursorProvider as
payload. |
Modifier and Type | Method and Description |
---|---|
<T> T |
FunctionalReadWriteLock.withReadLock(CheckedFunction<FunctionalReadWriteLock.LockReleaser,T> function)
Executes the given function under the protection of the read lock and returns the output value.
|
Copyright © 2018. All rights reserved.