Package | Description |
---|---|
org.osgi.util.converter |
Converter Package Version 1.0.
|
org.osgi.util.promise |
Promise Package Version 1.1.
|
org.osgi.util.pushstream |
Push Stream Package Version 1.0.
|
Modifier and Type | Method and Description |
---|---|
<T> Function<java.lang.Object,T> |
Functioning.to(java.lang.Class<T> cls)
Specify the target object type for the conversion as a class object.
|
<T> Function<java.lang.Object,T> |
Functioning.to(java.lang.reflect.Type type)
Specify the target object type as a Java Reflection Type object.
|
<T> Function<java.lang.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(java.lang.reflect.Type from,
java.lang.reflect.Type to,
Function<F,T> func)
Create an instance based on source, target types and a conversion
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,java.util.Optional<R>> f)
Coalesces a number of events into a new type of event.
|
<R> PushStream<R> |
PushStream.coalesce(int count,
Function<java.util.Collection<T>,R> f)
Coalesces a number of events into a new type of event.
|
<R> PushStream<R> |
PushStream.coalesce(java.util.function.IntSupplier count,
Function<java.util.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(java.time.Duration d,
java.util.concurrent.Executor executor,
Function<java.util.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(java.time.Duration d,
Function<java.util.Collection<T>,R> f)
Buffers a number of events over a fixed time interval and then forwards
the events to an accumulator function.
|
Copyright © OSGi Alliance (2000, 2018). All Rights Reserved. Licensed under the OSGi Specification License, Version 2.0