Package | Description |
---|---|
reactor.groovy.ext | |
reactor.io.net |
Reactive network components are located in this package scope implementing the following exposed contract:
A
ReactorPeer NetServer/NetClient is a Publisher of
ReactorChannel that are themselves Publisher of input data. |
reactor.io.net.http |
Components for writing HTTP-based clients and servers using Reactor abstractions.
|
reactor.io.net.impl.netty.http | |
reactor.io.net.impl.netty.tcp | |
reactor.io.net.impl.netty.udp | |
reactor.io.net.impl.zmq.tcp | |
reactor.io.net.udp | |
reactor.rx |
Streams are reactive components derived from Reactive Extensions and implementing Reactive Streams specification.
|
Modifier and Type | Method and Description |
---|---|
static <T> Promise<T> |
ReactorStaticExtensions.from(Promise<T> selfType,
groovy.lang.Closure<T> callback) |
static <T> Promise<T> |
StreamExtensions.leftShift(Promise<T> selfType,
Consumer<T> other) |
Modifier and Type | Method and Description |
---|---|
static <T> Stream<T> |
StreamExtensions.and(Promise<T> selfType,
Predicate<T> other) |
static <T> Promise<T> |
ReactorStaticExtensions.from(Promise<T> selfType,
groovy.lang.Closure<T> callback) |
static <T> Promise<T> |
StreamExtensions.leftShift(Promise<T> selfType,
Consumer<T> other) |
static <T,V> Stream<V> |
StreamExtensions.or(Promise<T> selfType,
Function<T,V> other) |
Modifier and Type | Method and Description |
---|---|
protected abstract Promise<Void> |
ReactorPeer.doShutdown() |
protected abstract Promise<Void> |
ReactorPeer.doStart(ReactorChannelHandler<IN,OUT,CONN> handler) |
Promise<Void> |
ReactorPeer.shutdown()
Shutdown this Peer and complete the returned
Promise when shut
down. |
Promise<Void> |
ReactorPeer.start(ReactorChannelHandler<IN,OUT,CONN> handler)
Start this Peer.
|
Modifier and Type | Method and Description |
---|---|
Promise<? extends HttpChannel<IN,OUT>> |
HttpClient.delete(String url)
HTTP DELETE the passed URL.
|
Promise<? extends HttpChannel<IN,OUT>> |
HttpClient.delete(String url,
ReactorChannelHandler<IN,OUT,HttpChannel<IN,OUT>> handler)
HTTP DELETE the passed URL.
|
Promise<? extends HttpChannel<IN,OUT>> |
HttpClient.get(String url)
HTTP GET the passed URL.
|
Promise<? extends HttpChannel<IN,OUT>> |
HttpClient.get(String url,
ReactorChannelHandler<IN,OUT,HttpChannel<IN,OUT>> handler)
HTTP GET the passed URL.
|
Promise<? extends HttpChannel<IN,OUT>> |
HttpClient.post(String url,
ReactorChannelHandler<IN,OUT,HttpChannel<IN,OUT>> handler)
HTTP POST the passed URL.
|
Promise<? extends HttpChannel<IN,OUT>> |
HttpClient.put(String url,
ReactorChannelHandler<IN,OUT,HttpChannel<IN,OUT>> handler)
HTTP PUT the passed URL.
|
abstract Promise<? extends HttpChannel<IN,OUT>> |
HttpClient.request(Method method,
String url,
ReactorChannelHandler<IN,OUT,HttpChannel<IN,OUT>> handler)
Use the passed HTTP method to send to the given URL.
|
Promise<Void> |
HttpServer.start()
Start the server without any global handler, only the specific routed methods (get, post...) will apply.
|
Promise<? extends HttpChannel<IN,OUT>> |
HttpClient.ws(String url)
WebSocket to the passed URL.
|
Promise<? extends HttpChannel<IN,OUT>> |
HttpClient.ws(String url,
ReactorChannelHandler<IN,OUT,HttpChannel<IN,OUT>> handler)
WebSocket to the passed URL.
|
Modifier and Type | Method and Description |
---|---|
protected Promise<Void> |
NettyHttpClient.doShutdown() |
protected Promise<Void> |
NettyHttpServer.doShutdown() |
protected Promise<Void> |
NettyHttpClient.doStart(ReactorChannelHandler<IN,OUT,HttpChannel<IN,OUT>> handler) |
protected Promise<Void> |
NettyHttpServer.doStart(ReactorChannelHandler<IN,OUT,HttpChannel<IN,OUT>> handler) |
Promise<? extends HttpChannel<IN,OUT>> |
NettyHttpClient.request(Method method,
String url,
ReactorChannelHandler<IN,OUT,HttpChannel<IN,OUT>> handler) |
Modifier and Type | Method and Description |
---|---|
protected Promise<Void> |
NettyTcpClient.doShutdown() |
Promise<Void> |
NettyTcpServer.doShutdown() |
protected Promise<Void> |
NettyTcpClient.doStart(ReactorChannelHandler<IN,OUT,ChannelStream<IN,OUT>> handler) |
protected Promise<Void> |
NettyTcpServer.doStart(ReactorChannelHandler<IN,OUT,ChannelStream<IN,OUT>> handler) |
Modifier and Type | Method and Description |
---|---|
protected Promise<Void> |
NettyDatagramServer.doShutdown() |
protected Promise<Void> |
NettyDatagramServer.doStart(ReactorChannelHandler<IN,OUT,ChannelStream<IN,OUT>> channelHandler) |
Promise<Void> |
NettyDatagramServer.join(InetAddress multicastAddress,
NetworkInterface iface) |
Promise<Void> |
NettyDatagramServer.leave(InetAddress multicastAddress,
NetworkInterface iface) |
Modifier and Type | Method and Description |
---|---|
Promise<ChannelStream<T,T>> |
ZeroMQ.createClient(String addrs,
int socketType) |
Promise<ChannelStream<T,T>> |
ZeroMQ.createServer(String addrs,
int socketType) |
Promise<ChannelStream<T,T>> |
ZeroMQ.dealer(String addrs) |
protected Promise<Void> |
ZeroMQTcpServer.doShutdown() |
protected Promise<Void> |
ZeroMQTcpClient.doShutdown() |
protected Promise<Void> |
ZeroMQTcpServer.doStart(ReactorChannelHandler<IN,OUT,ChannelStream<IN,OUT>> handler) |
protected Promise<Void> |
ZeroMQTcpClient.doStart(ReactorChannelHandler<IN,OUT,ChannelStream<IN,OUT>> handler) |
Promise<ChannelStream<T,T>> |
ZeroMQ.pull(String addrs) |
Promise<ChannelStream<T,T>> |
ZeroMQ.push(String addrs) |
Promise<ChannelStream<T,T>> |
ZeroMQ.reply(String addrs) |
Promise<ChannelStream<T,T>> |
ZeroMQ.request(String addrs) |
Promise<ChannelStream<T,T>> |
ZeroMQ.router(String addrs) |
Modifier and Type | Method and Description |
---|---|
Promise<Void> |
DatagramServer.join(InetAddress multicastAddress)
Join a multicast group.
|
abstract Promise<Void> |
DatagramServer.join(InetAddress multicastAddress,
NetworkInterface iface)
Join a multicast group.
|
Promise<Void> |
DatagramServer.leave(InetAddress multicastAddress)
Leave a multicast group.
|
abstract Promise<Void> |
DatagramServer.leave(InetAddress multicastAddress,
NetworkInterface iface)
Leave a multicast group.
|
Modifier and Type | Method and Description |
---|---|
Promise<Void> |
Promise.after()
Only forward onError and onComplete signals into the returned stream.
|
static <T> Promise<T> |
Promises.any(List<? extends Promise<T>> promises)
Pick the first result coming from any of the given promises and populate a new Promise.
|
static <T> Promise<T> |
Promises.any(Promise<T>... promises)
Pick the first result coming from any of the given promises and populate a new Promise.
|
static <T> Promise<T> |
Promises.error(Environment env,
Dispatcher dispatcher,
Throwable error)
|
static <T> Promise<T> |
Promises.error(Environment env,
Throwable error)
|
static <T> Promise<T> |
Promises.error(Throwable error)
|
<V> Promise<V> |
Promise.flatMap(Function<? super O,? extends org.reactivestreams.Publisher<? extends V>> transformation)
Assign a
Function that will either be invoked later, when the Promise is successfully completed
with
a value, or, if this Promise has already been fulfilled, is immediately scheduled to be executed on the
current Dispatcher . |
<V> Promise<V> |
Promise.map(Function<? super O,V> transformation)
Assign a
Function that will either be invoked later, when the Promise is successfully completed
with
a value, or, if this Promise has already been fulfilled, is immediately scheduled to be executed on the
current Dispatcher . |
Promise<O> |
Stream.next()
Return the promise of the next triggered signal.
|
Promise<O> |
Promise.onComplete(Consumer<Promise<O>> onComplete)
Assign a
Consumer that will either be invoked later, when the Promise is completed by either
setting a value or propagating an error, or, if this Promise has already been fulfilled, is immediately
scheduled to be executed on the current Dispatcher . |
Promise<O> |
Promise.onError(Consumer<Throwable> onError)
Assign a
Consumer that will either be invoked later, when the Promise is completed with an error,
or, if this Promise has already been fulfilled, is immediately scheduled to be executed on the current
Dispatcher . |
Promise<O> |
Promise.onSuccess(Consumer<O> onSuccess)
Assign a
Consumer that will either be invoked later, when the Promise is successfully completed
with
a value, or, if this Promise has already been fulfilled, is immediately scheduled to be executed on the
current Dispatcher . |
static <T> Promise<T> |
Promises.prepare()
Create a synchronous
Promise . |
static <T> Promise<T> |
Promises.prepare(Environment env)
Create a
Promise . |
static <T> Promise<T> |
Promises.ready(Environment env,
Dispatcher dispatcher)
Create a
Promise . |
static Promise<Void> |
Promises.success()
Create a
Promise already completed without any data. |
static <T> Promise<T> |
Promises.success(Environment env,
Dispatcher dispatcher,
T value)
|
static <T> Promise<T> |
Promises.success(Environment env,
T value)
|
static <T> Promise<T> |
Promises.success(T value)
|
static <T> Promise<T> |
Promises.syncTask(Supplier<T> supplier)
|
static <T> Promise<T> |
Promises.task(Environment env,
Dispatcher dispatcher,
Supplier<T> supplier)
|
static <T> Promise<T> |
Promises.task(Environment env,
Supplier<T> supplier)
|
Promise<List<O>> |
Stream.toList()
Fetch all values in a List to the returned Promise
|
Promise<List<O>> |
Stream.toList(long maximum)
Return the promise of N signals collected into an array list.
|
static <T> Promise<List<T>> |
Promises.when(List<? extends Promise<T>> promises)
Aggregate given promises into a new a Promise that will be fulfilled when all of the given Promise Promises have been fulfilled.
|
static <T1,T2> Promise<Tuple2<T1,T2>> |
Promises.when(Promise<T1> p1,
Promise<T2> p2)
Merge given promises into a new a Promise that will be fulfilled when all of the given Promise
Promises have been fulfilled.
|
static <T1,T2,T3> Promise<Tuple3<T1,T2,T3>> |
Promises.when(Promise<T1> p1,
Promise<T2> p2,
Promise<T3> p3)
Merge given promises into a new a Promise that will be fulfilled when all of the given Promise
Promises have been fulfilled.
|
static <T1,T2,T3,T4> |
Promises.when(Promise<T1> p1,
Promise<T2> p2,
Promise<T3> p3,
Promise<T4> p4)
Merge given promises into a new a Promise that will be fulfilled when all of the given Promise
Promises have been fulfilled.
|
static <T1,T2,T3,T4,T5> |
Promises.when(Promise<T1> p1,
Promise<T2> p2,
Promise<T3> p3,
Promise<T4> p4,
Promise<T5> p5)
Merge given promises into a new a Promise that will be fulfilled when all of the given Promise
Promises have been fulfilled.
|
static <T1,T2,T3,T4,T5,T6> |
Promises.when(Promise<T1> p1,
Promise<T2> p2,
Promise<T3> p3,
Promise<T4> p4,
Promise<T5> p5,
Promise<T6> p6)
Merge given promises into a new a Promise that will be fulfilled when all of the given Promise
Promises have been fulfilled.
|
static <T1,T2,T3,T4,T5,T6,T7> |
Promises.when(Promise<T1> p1,
Promise<T2> p2,
Promise<T3> p3,
Promise<T4> p4,
Promise<T5> p5,
Promise<T6> p6,
Promise<T7> p7)
Merge given promises into a new a Promise that will be fulfilled when all of the given Promise
Promises have been fulfilled.
|
static <T1,T2,T3,T4,T5,T6,T7,T8> |
Promises.when(Promise<T1> p1,
Promise<T2> p2,
Promise<T3> p3,
Promise<T4> p4,
Promise<T5> p5,
Promise<T6> p6,
Promise<T7> p7,
Promise<T8> p8)
Merge given promises into a new a Promise that will be fulfilled when all of the given Promise
Promises have been fulfilled.
|
Modifier and Type | Method and Description |
---|---|
static <T> Promise<T> |
Promises.any(Promise<T>... promises)
Pick the first result coming from any of the given promises and populate a new Promise.
|
static <T1,T2> Promise<Tuple2<T1,T2>> |
Promises.when(Promise<T1> p1,
Promise<T2> p2)
Merge given promises into a new a Promise that will be fulfilled when all of the given Promise
Promises have been fulfilled.
|
static <T1,T2> Promise<Tuple2<T1,T2>> |
Promises.when(Promise<T1> p1,
Promise<T2> p2)
Merge given promises into a new a Promise that will be fulfilled when all of the given Promise
Promises have been fulfilled.
|
static <T1,T2,T3> Promise<Tuple3<T1,T2,T3>> |
Promises.when(Promise<T1> p1,
Promise<T2> p2,
Promise<T3> p3)
Merge given promises into a new a Promise that will be fulfilled when all of the given Promise
Promises have been fulfilled.
|
static <T1,T2,T3> Promise<Tuple3<T1,T2,T3>> |
Promises.when(Promise<T1> p1,
Promise<T2> p2,
Promise<T3> p3)
Merge given promises into a new a Promise that will be fulfilled when all of the given Promise
Promises have been fulfilled.
|
static <T1,T2,T3> Promise<Tuple3<T1,T2,T3>> |
Promises.when(Promise<T1> p1,
Promise<T2> p2,
Promise<T3> p3)
Merge given promises into a new a Promise that will be fulfilled when all of the given Promise
Promises have been fulfilled.
|
static <T1,T2,T3,T4> |
Promises.when(Promise<T1> p1,
Promise<T2> p2,
Promise<T3> p3,
Promise<T4> p4)
Merge given promises into a new a Promise that will be fulfilled when all of the given Promise
Promises have been fulfilled.
|
static <T1,T2,T3,T4> |
Promises.when(Promise<T1> p1,
Promise<T2> p2,
Promise<T3> p3,
Promise<T4> p4)
Merge given promises into a new a Promise that will be fulfilled when all of the given Promise
Promises have been fulfilled.
|
static <T1,T2,T3,T4> |
Promises.when(Promise<T1> p1,
Promise<T2> p2,
Promise<T3> p3,
Promise<T4> p4)
Merge given promises into a new a Promise that will be fulfilled when all of the given Promise
Promises have been fulfilled.
|
static <T1,T2,T3,T4> |
Promises.when(Promise<T1> p1,
Promise<T2> p2,
Promise<T3> p3,
Promise<T4> p4)
Merge given promises into a new a Promise that will be fulfilled when all of the given Promise
Promises have been fulfilled.
|
static <T1,T2,T3,T4,T5> |
Promises.when(Promise<T1> p1,
Promise<T2> p2,
Promise<T3> p3,
Promise<T4> p4,
Promise<T5> p5)
Merge given promises into a new a Promise that will be fulfilled when all of the given Promise
Promises have been fulfilled.
|
static <T1,T2,T3,T4,T5> |
Promises.when(Promise<T1> p1,
Promise<T2> p2,
Promise<T3> p3,
Promise<T4> p4,
Promise<T5> p5)
Merge given promises into a new a Promise that will be fulfilled when all of the given Promise
Promises have been fulfilled.
|
static <T1,T2,T3,T4,T5> |
Promises.when(Promise<T1> p1,
Promise<T2> p2,
Promise<T3> p3,
Promise<T4> p4,
Promise<T5> p5)
Merge given promises into a new a Promise that will be fulfilled when all of the given Promise
Promises have been fulfilled.
|
static <T1,T2,T3,T4,T5> |
Promises.when(Promise<T1> p1,
Promise<T2> p2,
Promise<T3> p3,
Promise<T4> p4,
Promise<T5> p5)
Merge given promises into a new a Promise that will be fulfilled when all of the given Promise
Promises have been fulfilled.
|
static <T1,T2,T3,T4,T5> |
Promises.when(Promise<T1> p1,
Promise<T2> p2,
Promise<T3> p3,
Promise<T4> p4,
Promise<T5> p5)
Merge given promises into a new a Promise that will be fulfilled when all of the given Promise
Promises have been fulfilled.
|
static <T1,T2,T3,T4,T5,T6> |
Promises.when(Promise<T1> p1,
Promise<T2> p2,
Promise<T3> p3,
Promise<T4> p4,
Promise<T5> p5,
Promise<T6> p6)
Merge given promises into a new a Promise that will be fulfilled when all of the given Promise
Promises have been fulfilled.
|
static <T1,T2,T3,T4,T5,T6> |
Promises.when(Promise<T1> p1,
Promise<T2> p2,
Promise<T3> p3,
Promise<T4> p4,
Promise<T5> p5,
Promise<T6> p6)
Merge given promises into a new a Promise that will be fulfilled when all of the given Promise
Promises have been fulfilled.
|
static <T1,T2,T3,T4,T5,T6> |
Promises.when(Promise<T1> p1,
Promise<T2> p2,
Promise<T3> p3,
Promise<T4> p4,
Promise<T5> p5,
Promise<T6> p6)
Merge given promises into a new a Promise that will be fulfilled when all of the given Promise
Promises have been fulfilled.
|
static <T1,T2,T3,T4,T5,T6> |
Promises.when(Promise<T1> p1,
Promise<T2> p2,
Promise<T3> p3,
Promise<T4> p4,
Promise<T5> p5,
Promise<T6> p6)
Merge given promises into a new a Promise that will be fulfilled when all of the given Promise
Promises have been fulfilled.
|
static <T1,T2,T3,T4,T5,T6> |
Promises.when(Promise<T1> p1,
Promise<T2> p2,
Promise<T3> p3,
Promise<T4> p4,
Promise<T5> p5,
Promise<T6> p6)
Merge given promises into a new a Promise that will be fulfilled when all of the given Promise
Promises have been fulfilled.
|
static <T1,T2,T3,T4,T5,T6> |
Promises.when(Promise<T1> p1,
Promise<T2> p2,
Promise<T3> p3,
Promise<T4> p4,
Promise<T5> p5,
Promise<T6> p6)
Merge given promises into a new a Promise that will be fulfilled when all of the given Promise
Promises have been fulfilled.
|
static <T1,T2,T3,T4,T5,T6,T7> |
Promises.when(Promise<T1> p1,
Promise<T2> p2,
Promise<T3> p3,
Promise<T4> p4,
Promise<T5> p5,
Promise<T6> p6,
Promise<T7> p7)
Merge given promises into a new a Promise that will be fulfilled when all of the given Promise
Promises have been fulfilled.
|
static <T1,T2,T3,T4,T5,T6,T7> |
Promises.when(Promise<T1> p1,
Promise<T2> p2,
Promise<T3> p3,
Promise<T4> p4,
Promise<T5> p5,
Promise<T6> p6,
Promise<T7> p7)
Merge given promises into a new a Promise that will be fulfilled when all of the given Promise
Promises have been fulfilled.
|
static <T1,T2,T3,T4,T5,T6,T7> |
Promises.when(Promise<T1> p1,
Promise<T2> p2,
Promise<T3> p3,
Promise<T4> p4,
Promise<T5> p5,
Promise<T6> p6,
Promise<T7> p7)
Merge given promises into a new a Promise that will be fulfilled when all of the given Promise
Promises have been fulfilled.
|
static <T1,T2,T3,T4,T5,T6,T7> |
Promises.when(Promise<T1> p1,
Promise<T2> p2,
Promise<T3> p3,
Promise<T4> p4,
Promise<T5> p5,
Promise<T6> p6,
Promise<T7> p7)
Merge given promises into a new a Promise that will be fulfilled when all of the given Promise
Promises have been fulfilled.
|
static <T1,T2,T3,T4,T5,T6,T7> |
Promises.when(Promise<T1> p1,
Promise<T2> p2,
Promise<T3> p3,
Promise<T4> p4,
Promise<T5> p5,
Promise<T6> p6,
Promise<T7> p7)
Merge given promises into a new a Promise that will be fulfilled when all of the given Promise
Promises have been fulfilled.
|
static <T1,T2,T3,T4,T5,T6,T7> |
Promises.when(Promise<T1> p1,
Promise<T2> p2,
Promise<T3> p3,
Promise<T4> p4,
Promise<T5> p5,
Promise<T6> p6,
Promise<T7> p7)
Merge given promises into a new a Promise that will be fulfilled when all of the given Promise
Promises have been fulfilled.
|
static <T1,T2,T3,T4,T5,T6,T7> |
Promises.when(Promise<T1> p1,
Promise<T2> p2,
Promise<T3> p3,
Promise<T4> p4,
Promise<T5> p5,
Promise<T6> p6,
Promise<T7> p7)
Merge given promises into a new a Promise that will be fulfilled when all of the given Promise
Promises have been fulfilled.
|
static <T1,T2,T3,T4,T5,T6,T7,T8> |
Promises.when(Promise<T1> p1,
Promise<T2> p2,
Promise<T3> p3,
Promise<T4> p4,
Promise<T5> p5,
Promise<T6> p6,
Promise<T7> p7,
Promise<T8> p8)
Merge given promises into a new a Promise that will be fulfilled when all of the given Promise
Promises have been fulfilled.
|
static <T1,T2,T3,T4,T5,T6,T7,T8> |
Promises.when(Promise<T1> p1,
Promise<T2> p2,
Promise<T3> p3,
Promise<T4> p4,
Promise<T5> p5,
Promise<T6> p6,
Promise<T7> p7,
Promise<T8> p8)
Merge given promises into a new a Promise that will be fulfilled when all of the given Promise
Promises have been fulfilled.
|
static <T1,T2,T3,T4,T5,T6,T7,T8> |
Promises.when(Promise<T1> p1,
Promise<T2> p2,
Promise<T3> p3,
Promise<T4> p4,
Promise<T5> p5,
Promise<T6> p6,
Promise<T7> p7,
Promise<T8> p8)
Merge given promises into a new a Promise that will be fulfilled when all of the given Promise
Promises have been fulfilled.
|
static <T1,T2,T3,T4,T5,T6,T7,T8> |
Promises.when(Promise<T1> p1,
Promise<T2> p2,
Promise<T3> p3,
Promise<T4> p4,
Promise<T5> p5,
Promise<T6> p6,
Promise<T7> p7,
Promise<T8> p8)
Merge given promises into a new a Promise that will be fulfilled when all of the given Promise
Promises have been fulfilled.
|
static <T1,T2,T3,T4,T5,T6,T7,T8> |
Promises.when(Promise<T1> p1,
Promise<T2> p2,
Promise<T3> p3,
Promise<T4> p4,
Promise<T5> p5,
Promise<T6> p6,
Promise<T7> p7,
Promise<T8> p8)
Merge given promises into a new a Promise that will be fulfilled when all of the given Promise
Promises have been fulfilled.
|
static <T1,T2,T3,T4,T5,T6,T7,T8> |
Promises.when(Promise<T1> p1,
Promise<T2> p2,
Promise<T3> p3,
Promise<T4> p4,
Promise<T5> p5,
Promise<T6> p6,
Promise<T7> p7,
Promise<T8> p8)
Merge given promises into a new a Promise that will be fulfilled when all of the given Promise
Promises have been fulfilled.
|
static <T1,T2,T3,T4,T5,T6,T7,T8> |
Promises.when(Promise<T1> p1,
Promise<T2> p2,
Promise<T3> p3,
Promise<T4> p4,
Promise<T5> p5,
Promise<T6> p6,
Promise<T7> p7,
Promise<T8> p8)
Merge given promises into a new a Promise that will be fulfilled when all of the given Promise
Promises have been fulfilled.
|
static <T1,T2,T3,T4,T5,T6,T7,T8> |
Promises.when(Promise<T1> p1,
Promise<T2> p2,
Promise<T3> p3,
Promise<T4> p4,
Promise<T5> p5,
Promise<T6> p6,
Promise<T7> p7,
Promise<T8> p8)
Merge given promises into a new a Promise that will be fulfilled when all of the given Promise
Promises have been fulfilled.
|
Modifier and Type | Method and Description |
---|---|
static <T> Promise<T> |
Promises.any(List<? extends Promise<T>> promises)
Pick the first result coming from any of the given promises and populate a new Promise.
|
Promise<O> |
Promise.onComplete(Consumer<Promise<O>> onComplete)
Assign a
Consumer that will either be invoked later, when the Promise is completed by either
setting a value or propagating an error, or, if this Promise has already been fulfilled, is immediately
scheduled to be executed on the current Dispatcher . |
static <T> Promise<List<T>> |
Promises.when(List<? extends Promise<T>> promises)
Aggregate given promises into a new a Promise that will be fulfilled when all of the given Promise Promises have been fulfilled.
|
Copyright © 2016. All rights reserved.