Package | Description |
---|---|
org.osgi.util.converter |
Converter Package Version 1.0.
|
org.osgi.util.function |
Function Package Version 1.2.
|
org.osgi.util.promise |
Promise Package Version 1.2.
|
org.osgi.util.pushstream |
Push Stream Package Version 1.0.
|
Modifier and Type | Method and Description |
---|---|
<T> Function<Object,T> |
Functioning.to(Class<T> cls)
Specify the target object type for the conversion as a class object.
|
<T> Function<Object,T> |
Functioning.to(Type type)
Specify the target object type as a Java Reflection Type object.
|
<T> Function<Object,T> |
Functioning.to(TypeReference<T> ref)
Specify the target object type as a
TypeReference . |
Constructor and Description |
---|
Rule(Function<F,T> func)
Create an instance with a conversion function.
|
TypeRule(Type from,
Type to,
Function<F,T> func)
Create an instance based on source, target types and a conversion
function.
|
Modifier and Type | Method and Description |
---|---|
default <S> Function<T,S> |
Function.andThen(Function<? super R,? extends S> after)
Compose the specified
Function to be called on the value returned
by this Function . |
static <T,R> Function<T,R> |
Function.asFunction(Function<T,R> wrapped)
Returns a
Function which wraps the specified
java.util.function.Function . |
default <S> Function<S,R> |
Function.compose(Function<? super S,? extends T> before)
Compose the specified
Function to be called to supply a value to
be consumed by this Function . |
Modifier and Type | Method and Description |
---|---|
default <S> Function<T,S> |
Function.andThen(Function<? super R,? extends S> after)
Compose the specified
Function to be called on the value returned
by this Function . |
static <T,R> Function<T,R> |
Function.asJavaFunction(Function<T,R> wrapped)
Returns a
java.util.function.Function which wraps the specified
Function and throws any thrown exceptions. |
static <T,R> Function<T,R> |
Function.asJavaFunctionOrElse(Function<T,R> wrapped,
R orElse)
Returns a
java.util.function.Function which wraps the specified
Function and the specified value. |
static <T,R> Function<T,R> |
Function.asJavaFunctionOrElseGet(Function<T,R> wrapped,
Supplier<? extends R> orElseGet)
Returns a
java.util.function.Function which wraps the specified
Function and the specified java.util.function.Supplier . |
default <S> Function<S,R> |
Function.compose(Function<? super S,? extends T> before)
Compose the specified
Function to be called to supply a value to
be consumed by this Function . |
Modifier and Type | Method and Description |
---|---|
<R> Promise<R> |
Promise.flatMap(Function<? super T,Promise<? extends R>> mapper)
FlatMap the value of this Promise.
|
<R> Promise<R> |
Promise.map(Function<? super T,? extends R> mapper)
Map the value of this Promise.
|
Promise<T> |
Promise.recover(Function<Promise<?>,? extends T> recovery)
Recover from a failure of this Promise with a recovery value.
|
Promise<T> |
Promise.recoverWith(Function<Promise<?>,Promise<? extends T>> recovery)
Recover from a failure of this Promise with a recovery Promise.
|
Modifier and Type | Method and Description |
---|---|
<R> PushStream<R> |
PushStream.asyncMap(int n,
int delay,
Function<? super T,Promise<? extends R>> mapper)
Asynchronously map the payload values.
|
<R> PushStream<R> |
PushStream.coalesce(Function<? super T,Optional<R>> f)
Coalesces a number of events into a new type of event.
|
<R> PushStream<R> |
PushStream.coalesce(int count,
Function<Collection<T>,R> f)
Coalesces a number of events into a new type of event.
|
<R> PushStream<R> |
PushStream.coalesce(IntSupplier count,
Function<Collection<T>,R> f)
Coalesces a number of events into a new type of event.
|
<R> PushStream<R> |
PushStream.flatMap(Function<? super T,? extends PushStream<? extends R>> mapper)
Flat map the payload value (turn one event into 0..n events of
potentially another type).
|
<R> PushStream<R> |
PushStream.map(Function<? super T,? extends R> mapper)
Map a payload value.
|
<R> PushStream<R> |
PushStream.window(Duration d,
Executor executor,
Function<Collection<T>,R> f)
Buffers a number of events over a fixed time interval and then forwards
the events to an accumulator function.
|
<R> PushStream<R> |
PushStream.window(Duration d,
Function<Collection<T>,R> f)
Buffers a number of events over a fixed time interval and then forwards
the events to an accumulator function.
|
Copyright © Contributors to the Eclipse Foundation Licensed under the Eclipse Foundation Specification License – v1.0