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> |
FunctioningImpl.to(java.lang.Class<T> cls) |
<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> |
FunctioningImpl.to(java.lang.reflect.Type type) |
<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> |
FunctioningImpl.to(TypeReference<T> ref) |
<T> Function<java.lang.Object,T> |
Functioning.to(TypeReference<T> ref)
Specify the target object type as a
TypeReference . |
Modifier and Type | Method and Description |
---|---|
private static <F,T> ConverterFunction |
TypeRule.getFunction(java.lang.reflect.Type from,
Function<F,T> func) |
private ConverterFunction |
Rule.getGenericFunction(Function<F,T> func) |
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 | Field and Description |
---|---|
private Function<? super P,? extends T> |
DeferredPromiseImpl.Map.mapper |
private Function<? super P,Promise<? extends T>> |
DeferredPromiseImpl.FlatMap.mapper |
private Function<Promise<?>,? extends T> |
DeferredPromiseImpl.Recover.recovery |
private Function<Promise<?>,Promise<? extends T>> |
DeferredPromiseImpl.RecoverWith.recovery |
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> |
FailedPromiseImpl.flatMap(Function<? super T,Promise<? extends R>> mapper)
FlatMap the value of this Promise.
|
<R> Promise<R> |
PromiseImpl.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.
|
<R> Promise<R> |
FailedPromiseImpl.map(Function<? super T,? extends R> mapper)
Map the value of this Promise.
|
<R> Promise<R> |
PromiseImpl.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> |
PromiseImpl.recover(Function<Promise<?>,? extends T> recovery)
Recover from a failure of this Promise with a recovery value.
|
Promise<T> |
ResolvedPromiseImpl.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.
|
Promise<T> |
PromiseImpl.recoverWith(Function<Promise<?>,Promise<? extends T>> recovery)
Recover from a failure of this Promise with a recovery Promise.
|
Promise<T> |
ResolvedPromiseImpl.recoverWith(Function<Promise<?>,Promise<? extends T>> recovery)
Recover from a failure of this Promise with a recovery Promise.
|
Constructor and Description |
---|
FlatMap(PromiseImpl<P> promise,
Function<? super P,Promise<? extends T>> mapper) |
Map(PromiseImpl<P> promise,
Function<? super P,? extends T> mapper) |
Recover(PromiseImpl<T> promise,
Function<Promise<?>,? extends T> recovery) |
RecoverWith(PromiseImpl<T> promise,
Function<Promise<?>,Promise<? extends T>> recovery) |
Modifier and Type | Field and Description |
---|---|
private Function<T,T> |
AbstractPushStreamImpl.IDENTITY |
Modifier and Type | Method and Description |
---|---|
private <R> long |
AbstractPushStreamImpl.aggregateAndForward(Function<java.util.Collection<T>,R> f,
AbstractPushStreamImpl<R> eventStream,
PushEvent<? extends T> event,
java.util.Queue<T> queue) |
<R> PushStream<R> |
AbstractPushStreamImpl.asyncMap(int n,
int delay,
Function<? super T,Promise<? extends R>> mapper) |
<R> PushStream<R> |
PushStream.asyncMap(int n,
int delay,
Function<? super T,Promise<? extends R>> mapper)
Asynchronously map the payload values.
|
<R> PushStream<R> |
AbstractPushStreamImpl.coalesce(Function<? super T,java.util.Optional<R>> accumulator) |
<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> |
AbstractPushStreamImpl.coalesce(int count,
Function<java.util.Collection<T>,R> f) |
<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> |
AbstractPushStreamImpl.coalesce(java.util.function.IntSupplier count,
Function<java.util.Collection<T>,R> f) |
<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> |
AbstractPushStreamImpl.flatMap(Function<? super T,? extends PushStream<? extends R>> mapper) |
<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> |
AbstractPushStreamImpl.map(Function<? super T,? extends R> mapper) |
<R> PushStream<R> |
PushStream.map(Function<? super T,? extends R> mapper)
Map a payload value.
|
<R> PushStream<R> |
AbstractPushStreamImpl.window(java.time.Duration time,
java.util.concurrent.Executor executor,
Function<java.util.Collection<T>,R> f) |
<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> |
AbstractPushStreamImpl.window(java.time.Duration time,
Function<java.util.Collection<T>,R> f) |
<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.
|