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 a TypeReference.
<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> ConverterFunction	TypeRule.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.