Uses of Interface
org.osgi.util.function.Function
-
Packages that use Function 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. -
-
Uses of Function in org.osgi.util.converter
Methods in org.osgi.util.converter that return Function Modifier and Type Method 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 aTypeReference
.<T> Function<java.lang.Object,T>
FunctioningImpl. to(java.lang.Class<T> cls)
<T> Function<java.lang.Object,T>
FunctioningImpl. to(java.lang.reflect.Type type)
<T> Function<java.lang.Object,T>
FunctioningImpl. to(TypeReference<T> ref)
Methods in org.osgi.util.converter with parameters of type Function Modifier and Type Method Description private static <F,T>
ConverterFunctionTypeRule. getFunction(java.lang.reflect.Type from, Function<F,T> func)
private ConverterFunction
Rule. getGenericFunction(Function<F,T> func)
Constructors in org.osgi.util.converter with parameters of type Function Constructor 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. -
Uses of Function in org.osgi.util.promise
Fields in org.osgi.util.promise declared as Function Modifier and Type Field Description private Function<? super P,Promise<? extends T>>
DeferredPromiseImpl.FlatMap. mapper
private Function<? super P,? extends T>
DeferredPromiseImpl.Map. mapper
private Function<Promise<?>,? extends T>
DeferredPromiseImpl.Recover. recovery
private Function<Promise<?>,Promise<? extends T>>
DeferredPromiseImpl.RecoverWith. recovery
Methods in org.osgi.util.promise with parameters of type Function Modifier and Type Method Description <R> Promise<R>
FailedPromiseImpl. flatMap(Function<? super T,Promise<? extends R>> mapper)
FlatMap the value of this Promise.<R> Promise<R>
Promise. 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>
FailedPromiseImpl. map(Function<? super T,? extends R> mapper)
Map 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>
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.Constructors in org.osgi.util.promise with parameters of type Function Constructor 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)
-
Uses of Function in org.osgi.util.pushstream
Fields in org.osgi.util.pushstream declared as Function Modifier and Type Field Description private Function<T,T>
AbstractPushStreamImpl. IDENTITY
Methods in org.osgi.util.pushstream with parameters of type Function Modifier and Type Method 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(int count, Function<java.util.Collection<T>,R> f)
<R> PushStream<R>
AbstractPushStreamImpl. coalesce(java.util.function.IntSupplier count, Function<java.util.Collection<T>,R> f)
<R> PushStream<R>
AbstractPushStreamImpl. coalesce(Function<? super T,java.util.Optional<R>> accumulator)
<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. coalesce(Function<? super T,java.util.Optional<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>
AbstractPushStreamImpl. window(java.time.Duration time, 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>
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.
-