Uses of Interface
org.osgi.util.function.Function
Packages that use Function
Package
Description
Converter Package Version 1.0.
Promise Package Version 1.1.
Push Stream Package Version 1.0.
-
Uses of Function in org.osgi.util.converter
Methods in org.osgi.util.converter that return FunctionModifier and TypeMethodDescriptionSpecify the target object type for the conversion as a class object.Specify the target object type as a Java Reflection Type object.Functioning.to
(TypeReference<T> ref) Specify the target object type as aTypeReference
.FunctioningImpl.to
(TypeReference<T> ref) Methods in org.osgi.util.converter with parameters of type FunctionModifier and TypeMethodDescriptionprivate static <F,
T> ConverterFunction TypeRule.getFunction
(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 -
Uses of Function in org.osgi.util.promise
Fields in org.osgi.util.promise declared as FunctionModifier and TypeFieldDescriptionDeferredPromiseImpl.FlatMap.mapper
DeferredPromiseImpl.Map.mapper
DeferredPromiseImpl.Recover.recovery
DeferredPromiseImpl.RecoverWith.recovery
Methods in org.osgi.util.promise with parameters of type FunctionModifier and TypeMethodDescription<R> Promise
<R> FlatMap the value of this Promise.<R> Promise
<R> FlatMap the value of this Promise.<R> Promise
<R> FlatMap the value of this Promise.<R> Promise
<R> Map the value of this Promise.<R> Promise
<R> Map the value of this Promise.<R> Promise
<R> Map the value of this Promise.Recover from a failure of this Promise with a recovery value.Recover from a failure of this Promise with a recovery value.Recover from a failure of this Promise with a recovery value.Promise.recoverWith
(Function<Promise<?>, Promise<? extends T>> recovery) Recover from a failure of this Promise with a recovery Promise.PromiseImpl.recoverWith
(Function<Promise<?>, Promise<? extends T>> recovery) Recover from a failure of this Promise with a recovery Promise.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 FunctionModifierConstructorDescription(package private)
(package private)
(package private)
(package private)
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 FunctionMethods in org.osgi.util.pushstream with parameters of type FunctionModifier and TypeMethodDescriptionprivate <R> long
AbstractPushStreamImpl.aggregateAndForward
(Function<Collection<T>, R> f, AbstractPushStreamImpl<R> eventStream, PushEvent<? extends T> event, Queue<T> queue) <R> PushStream
<R> <R> PushStream
<R> Asynchronously map the payload values.<R> PushStream
<R> AbstractPushStreamImpl.coalesce
(int count, Function<Collection<T>, R> f) <R> PushStream
<R> AbstractPushStreamImpl.coalesce
(IntSupplier count, Function<Collection<T>, R> f) <R> PushStream
<R> <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> 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> <R> PushStream
<R> Map a payload value.<R> PushStream
<R> <R> PushStream
<R> AbstractPushStreamImpl.window
(Duration time, Function<Collection<T>, R> f) <R> PushStream
<R> 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.