Uses of Interface
org.osgi.util.promise.Promise

Packages that use Promise

Package	Description
org.osgi.service.async	Asynchronous Services Package Version 1.0.
org.osgi.service.async.delegate	Asynchronous Services Delegation Package Version 1.0.
org.osgi.service.component.runtime	Service Component Runtime Package Version 1.5.
org.osgi.service.jaxrs.client	JAX-RS Client Package Version 1.0.
org.osgi.service.onem2m	Service Layer API for oneM2M Specification Package Version 1.0.
org.osgi.service.repository	Repository Service Package Version 1.1.
org.osgi.service.zigbee	Device Service Specification for ZigBee Technology.
org.osgi.util.promise	Promise Package Version 1.2.
org.osgi.util.pushstream	Push Stream Package Version 1.0.

Uses of Promise in org.osgi.service.async

Methods in org.osgi.service.async that return Promise

Modifier and Type	Method and Description
Promise<?>	Async.call() Invoke the last method call registered by a mediated object as an asynchronous task.
<R> Promise<R>	Async.call(R r) Invoke the last method call registered by a mediated object as an asynchronous task.
Promise<Void>	Async.execute() Invoke the last method call registered by a mediated object as a "fire-and-forget" asynchronous task.

Uses of Promise in org.osgi.service.async.delegate

Methods in org.osgi.service.async.delegate that return Promise

Modifier and Type	Method and Description
Promise<?>	AsyncDelegate.async(Method m, Object[] args) Invoke the specified method as an asynchronous task with the specified arguments.

Uses of Promise in org.osgi.service.component.runtime

Methods in org.osgi.service.component.runtime that return Promise

Modifier and Type	Method and Description
Promise<Void>	ServiceComponentRuntime.disableComponent(ComponentDescriptionDTO description) Disables the specified component description.
Promise<Void>	ServiceComponentRuntime.enableComponent(ComponentDescriptionDTO description) Enables the specified component description.

Uses of Promise in org.osgi.service.jaxrs.client

Methods in org.osgi.service.jaxrs.client that return Promise

Modifier and Type	Method and Description
Promise<javax.ws.rs.core.Response>	PromiseRxInvoker.delete()
<R> Promise<R>	PromiseRxInvoker.delete(Class<R> arg0)
<R> Promise<R>	PromiseRxInvoker.delete(javax.ws.rs.core.GenericType<R> arg0)
Promise<javax.ws.rs.core.Response>	PromiseRxInvoker.get()
<R> Promise<R>	PromiseRxInvoker.get(Class<R> arg0)
<R> Promise<R>	PromiseRxInvoker.get(javax.ws.rs.core.GenericType<R> arg0)
Promise<javax.ws.rs.core.Response>	PromiseRxInvoker.head()
Promise<javax.ws.rs.core.Response>	PromiseRxInvoker.method(String arg0)
<R> Promise<R>	PromiseRxInvoker.method(String arg0, Class<R> arg1)
Promise<javax.ws.rs.core.Response>	PromiseRxInvoker.method(String arg0, javax.ws.rs.client.Entity<?> arg1)
<R> Promise<R>	PromiseRxInvoker.method(String arg0, javax.ws.rs.client.Entity<?> arg1, Class<R> arg2)
<R> Promise<R>	PromiseRxInvoker.method(String arg0, javax.ws.rs.client.Entity<?> arg1, javax.ws.rs.core.GenericType<R> arg2)
<R> Promise<R>	PromiseRxInvoker.method(String arg0, javax.ws.rs.core.GenericType<R> arg1)
Promise<javax.ws.rs.core.Response>	PromiseRxInvoker.options()
<R> Promise<R>	PromiseRxInvoker.options(Class<R> arg0)
<R> Promise<R>	PromiseRxInvoker.options(javax.ws.rs.core.GenericType<R> arg0)
Promise<javax.ws.rs.core.Response>	PromiseRxInvoker.post(javax.ws.rs.client.Entity<?> arg0)
<R> Promise<R>	PromiseRxInvoker.post(javax.ws.rs.client.Entity<?> arg0, Class<R> arg1)
<R> Promise<R>	PromiseRxInvoker.post(javax.ws.rs.client.Entity<?> arg0, javax.ws.rs.core.GenericType<R> arg1)
Promise<javax.ws.rs.core.Response>	PromiseRxInvoker.put(javax.ws.rs.client.Entity<?> arg0)
<R> Promise<R>	PromiseRxInvoker.put(javax.ws.rs.client.Entity<?> arg0, Class<R> arg1)
<R> Promise<R>	PromiseRxInvoker.put(javax.ws.rs.client.Entity<?> arg0, javax.ws.rs.core.GenericType<R> arg1)
Promise<javax.ws.rs.core.Response>	PromiseRxInvoker.trace()
<R> Promise<R>	PromiseRxInvoker.trace(Class<R> arg0)
<R> Promise<R>	PromiseRxInvoker.trace(javax.ws.rs.core.GenericType<R> arg0)

Uses of Promise in org.osgi.service.onem2m

Methods in org.osgi.service.onem2m that return Promise

Modifier and Type	Method and Description
Promise<ResourceDTO>	ServiceLayer.create(String uri, ResourceDTO resource) create resource
Promise<Boolean>	ServiceLayer.delete(String uri) delete resource
Promise<List<String>>	ServiceLayer.discovery(String uri, FilterCriteriaDTO fc) find resources with filter condition specified in fc argument.
Promise<List<String>>	ServiceLayer.discovery(String uri, FilterCriteriaDTO fc, RequestPrimitiveDTO.DesiredIdentifierResultType drt) find resources with filter condition specified in fc argument.
Promise<Boolean>	ServiceLayer.notify(String uri, NotificationDTO notification) send notification
Promise<ResponsePrimitiveDTO>	ServiceLayer.request(RequestPrimitiveDTO request) send a request and receive response.
Promise<ResourceDTO>	ServiceLayer.retrieve(String uri) retrieve resource
Promise<ResourceDTO>	ServiceLayer.retrieve(String uri, List<String> targetAttributes) retrieve resource with selected attributes.
Promise<ResourceDTO>	ServiceLayer.update(String uri, ResourceDTO resource) update resource

Uses of Promise in org.osgi.service.repository

Methods in org.osgi.service.repository that return Promise

Modifier and Type	Method and Description
Promise<Collection<Resource>>	Repository.findProviders(RequirementExpression expression) Find the resources that match the specified requirement expression.

Uses of Promise in org.osgi.service.zigbee

Methods in org.osgi.service.zigbee that return Promise

Modifier and Type	Method and Description
Promise<Void>	ZigBeeEndpoint.bind(String servicePid, int clusterId) Adds the following entry in the Binding Table of the device:
Promise<ZCLAttribute>	ZCLCluster.getAttribute(int attributeId) Returns the cluster ZCLAttribute identifying that matches the given attributeId.
Promise<ZCLAttribute>	ZCLCluster.getAttribute(int attributeId, int code) Retrieves a ZCLAttribute object for a manufacturer specific attribute.
Promise<ZCLAttribute[]>	ZCLCluster.getAttributes() Returns an array of ZCLAttribute objects representing all this cluster's attributes.
Promise<ZCLAttribute[]>	ZCLCluster.getAttributes(int code) Returns an array of ZCLAttribute objects representing all the specific manufacturer attributes available on the cluster.
Promise<List<String>>	ZigBeeEndpoint.getBoundEndPoints(int clusterId) Returns bound endpoints (identified by their service PIDs) on a specific cluster ID.
Promise<short[]>	ZCLCluster.getCommandIds() Returns an array of all the commandIds of the ZCLCluster.
Promise<ZigBeeComplexDescriptor>	ZigBeeNode.getComplexDescriptor() Retrieves the ZigBee node Complex Descriptor.
Promise<Map<String,ZigBeeLinkQuality>>	ZigBeeNode.getLinksQuality() Retrieves the link quality information to the neighbor nodes.
Promise<ZigBeeNodeDescriptor>	ZigBeeNode.getNodeDescriptor() Retrieves the ZigBee node Node Descriptor.
Promise<ZigBeePowerDescriptor>	ZigBeeNode.getPowerDescriptor() Retrieves the ZigBee node Power Descriptor.
Promise<ZCLFrame>	ZCLCommandResponse.getResponse() Returns a promise holding the response.
Promise<Map<String,ZigBeeRoute>>	ZigBeeNode.getRoutingTable() Retrieves the routing table information of the node.
Promise<ZigBeeSimpleDescriptor>	ZigBeeEndpoint.getSimpleDescriptor() Returns the simple descriptor of this endpoint.
Promise<String>	ZigBeeNode.getUserDescription() Returns the user description of this node.
Promise<Object>	ZCLAttribute.getValue() Gets the current value of the attribute.
Promise<ZDPFrame>	ZigBeeNode.invoke(int clusterIdReq, int expectedClusterIdRsp, ZDPFrame message) Sends the ZDPFrame to this ZigBeeNode with the specified cluster id.
Promise<ZDPFrame>	ZigBeeNode.invoke(int clusterIdReq, ZDPFrame message) Sends the ZDPFrame to this ZigBeeNode with the specified cluster id.
Promise<ZCLFrame>	ZCLCluster.invoke(ZCLFrame frame) Invokes a command on this cluster with a ZCLFrame.
Promise<ZCLFrame>	ZCLCluster.invoke(ZCLFrame frame, String exportedServicePID) Invokes a command on this cluster.
Promise<Void>	ZigBeeGroup.joinGroup(String pid) Requests an endpoint to join this group.
Promise<Void>	ZigBeeNode.leave() Requests this node to leave the ZigBee network.
Promise<Void>	ZigBeeNode.leave(boolean rejoin, boolean removeChildren) Requests the device to leave the network.
Promise<Void>	ZigBeeGroup.leaveGroup(String pid) Requests an endpoint to leave this group.
Promise<Map<Integer,ZCLReadStatusRecord>>	ZCLCluster.readAttributes(ZCLAttributeInfo[] attributes) Reads a list of attributes by issuing a ZCL Read Attributes command.
Promise<Boolean>	ZigBeeHost.refreshNetwork() Forces a new network scan.
Promise<Void>	ZigBeeNode.setUserDescription(String userDescription) Sets the user description of this node.
Promise<Void>	ZCLAttribute.setValue(Object value) Sets the current value of the attribute.
Promise<Void>	ZigBeeEndpoint.unbind(String servicePid, int clusterId) Removes the following entry in the Binding Table of the device if it exists:
Promise<Map<Integer,Integer>>	ZCLCluster.writeAttributes(boolean undivided, Map<? extends ZCLAttributeInfo,?> attributesAndValues) Writes a set of attributes on the cluster using the ZCL Write Attributes or the Write Attributes Undivided commands, according to the passed undivided parameter.

Uses of Promise in org.osgi.util.promise

Methods in org.osgi.util.promise that return Promise

Modifier and Type	Method and Description
<T,S extends T> Promise<List<T>>	PromiseFactory.all(Collection<Promise<S>> promises) Returns a new Promise that is a latch on the resolution of the specified Promises.
static <T,S extends T> Promise<List<T>>	Promises.all(Collection<Promise<S>> promises) Returns a new Promise that is a latch on the resolution of the specified Promises.
static <T> Promise<List<T>>	Promises.all(Promise<? extends T>... promises) Returns a new Promise that is a latch on the resolution of the specified Promises.
Promise<R>	Success.call(Promise<T> resolved) Success callback for a Promise.
Promise<T>	Promise.delay(long milliseconds) Delay after the resolution of this Promise.
<T> Promise<T>	PromiseFactory.failed(Throwable failure) Returns a new Promise that has been resolved with the specified failure.
static <T> Promise<T>	Promises.failed(Throwable failure) Returns a new Promise that has been resolved with the specified failure.
Promise<T>	Promise.fallbackTo(Promise<? extends T> fallback) Fall back to the value of the specified Promise if this Promise fails.
Promise<T>	Promise.filter(Predicate<? super T> predicate) Filter the value of this Promise.
<R> Promise<R>	Promise.flatMap(Function<? super T,Promise<? extends R>> mapper) FlatMap the value of this Promise.
Promise<T>	Deferred.getPromise() Returns the Promise associated with this Deferred.
<R> Promise<R>	Promise.map(Function<? super T,? extends R> mapper) Map the value of this Promise.
Promise<T>	Promise.onFailure(Consumer<? super Throwable> failure) Register a callback to be called with the failure for this Promise when this Promise is resolved with a failure.
Promise<T>	Promise.onResolve(Runnable callback) Register a callback to be called when this Promise is resolved.
Promise<T>	Promise.onSuccess(Consumer<? super T> success) Register a callback to be called with the result of this Promise when this Promise is resolved successfully.
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.
<T> Promise<T>	PromiseFactory.resolved(T value) Returns a new Promise that has been resolved with the specified value.
static <T> Promise<T>	Promises.resolved(T value) Returns a new Promise that has been resolved with the specified value.
<T> Promise<T>	PromiseFactory.resolvedWith(CompletionStage<? extends T> with) Returns a new Promise that will be resolved with the result of the specified CompletionStage.
<T> Promise<T>	PromiseFactory.resolvedWith(Promise<? extends T> with) Returns a new Promise that will be resolved with the specified Promise.
Promise<Void>	Deferred.resolveWith(CompletionStage<? extends T> with) Resolve the Promise associated with this Deferred with the specified CompletionStage.
Promise<Void>	Deferred.resolveWith(Promise<? extends T> with) Resolve the Promise associated with this Deferred with the specified Promise.
<T> Promise<T>	PromiseFactory.submit(Callable<? extends T> task) Returns a new Promise that will hold the result of the specified task.
<R> Promise<R>	Promise.then(Success<? super T,? extends R> success) Chain a new Promise to this Promise with a Success callback.
<R> Promise<R>	Promise.then(Success<? super T,? extends R> success, Failure failure) Chain a new Promise to this Promise with Success and Failure callbacks.
Promise<T>	Promise.thenAccept(Consumer<? super T> consumer) Chain a new Promise to this Promise with a Consumer callback that receives the value of this Promise when it is successfully resolved.
Promise<T>	Promise.timeout(long milliseconds) Time out the resolution of this Promise.

Methods in org.osgi.util.promise that return types with arguments of type Promise

Modifier and Type	Method and Description
Collection<Promise<?>>	FailedPromisesException.getFailedPromises() Returns the collection of Promises that have been resolved with a failure.
<T,S extends T> Collector<Promise<S>,?,Promise<List<T>>>	PromiseFactory.toPromise() Returns a Collector that accumulates the results of the input Promises into a new PromiseFactory.all(Collection) Promise.
<T,S extends T> Collector<Promise<S>,?,Promise<List<T>>>	PromiseFactory.toPromise() Returns a Collector that accumulates the results of the input Promises into a new PromiseFactory.all(Collection) Promise.

Methods in org.osgi.util.promise with parameters of type Promise

Modifier and Type	Method and Description
static <T> Promise<List<T>>	Promises.all(Promise<? extends T>... promises) Returns a new Promise that is a latch on the resolution of the specified Promises.
Promise<R>	Success.call(Promise<T> resolved) Success callback for a Promise.
void	Failure.fail(Promise<?> resolved) Failure callback for a Promise.
Promise<T>	Promise.fallbackTo(Promise<? extends T> fallback) Fall back to the value of the specified Promise if this Promise fails.
<T> Promise<T>	PromiseFactory.resolvedWith(Promise<? extends T> with) Returns a new Promise that will be resolved with the specified Promise.
Promise<Void>	Deferred.resolveWith(Promise<? extends T> with) Resolve the Promise associated with this Deferred with the specified Promise.

Method parameters in org.osgi.util.promise with type arguments of type Promise

Modifier and Type	Method and Description
<T,S extends T> Promise<List<T>>	PromiseFactory.all(Collection<Promise<S>> promises) Returns a new Promise that is a latch on the resolution of the specified Promises.
static <T,S extends T> Promise<List<T>>	Promises.all(Collection<Promise<S>> promises) Returns a new Promise that is a latch on the resolution of the specified Promises.
<R> Promise<R>	Promise.flatMap(Function<? super T,Promise<? extends R>> mapper) FlatMap 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.
Promise<T>	Promise.recoverWith(Function<Promise<?>,Promise<? extends T>> recovery) Recover from a failure of this Promise with a recovery Promise.

Constructor parameters in org.osgi.util.promise with type arguments of type Promise

Constructor and Description
FailedPromisesException(Collection<Promise<?>> failed, Throwable cause) Create a new FailedPromisesException with the specified Promises.

Uses of Promise in org.osgi.util.pushstream

Methods in org.osgi.util.pushstream that return Promise

Modifier and Type	Method and Description
Promise<Boolean>	PushStream.allMatch(Predicate<? super T> predicate) Closes the channel and resolve the promise with false when the predicate does not matches a pay load.
Promise<Boolean>	PushStream.anyMatch(Predicate<? super T> predicate) Close the channel and resolve the promise with true when the predicate matches a payload.
<R,A> Promise<R>	PushStream.collect(Collector<? super T,A,R> collector) See Stream.
Promise<Void>	SimplePushEventSource.connectPromise() This method can be used to delay event generation until an event source has connected.
Promise<Long>	PushStream.count() See Stream.
Promise<Optional<T>>	PushStream.findAny() Close the channel and resolve the promise with the first element.
Promise<Optional<T>>	PushStream.findFirst() Close the channel and resolve the promise with the first element.
Promise<Void>	PushStream.forEach(Consumer<? super T> action) Execute the action for each event received until the channel is closed.
Promise<Long>	PushStream.forEachEvent(PushEventConsumer<? super T> action) Pass on each event to another consumer until the stream is closed.
Promise<Optional<T>>	PushStream.max(Comparator<? super T> comparator) See Stream.
Promise<Optional<T>>	PushStream.min(Comparator<? super T> comparator) See Stream.
Promise<Boolean>	PushStream.noneMatch(Predicate<? super T> predicate) Closes the channel and resolve the promise with false when the predicate matches any pay load.
Promise<Optional<T>>	PushStream.reduce(BinaryOperator<T> accumulator) Standard reduce without identity, so the return is an Optional.
Promise<T>	PushStream.reduce(T identity, BinaryOperator<T> accumulator) Standard reduce, see Stream.
<U> Promise<U>	PushStream.reduce(U identity, BiFunction<U,? super T,U> accumulator, BinaryOperator<U> combiner) Standard reduce with identity, accumulator and combiner.
Promise<Object[]>	PushStream.toArray() Collect the payloads in an Object array after the channel is closed.
<A> Promise<A[]>	PushStream.toArray(IntFunction<A[]> generator) Collect the payloads in an Object array after the channel is closed.

Method parameters in org.osgi.util.pushstream with type arguments of type 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.