Package com.neovisionaries.ws.client

Class SocketInitiator.SocketFuture

java.lang.Object

com.neovisionaries.ws.client.SocketInitiator.SocketFuture

Enclosing class:

SocketInitiator

private class SocketInitiator.SocketFuture
extends Object

The socket future is shared across all SocketInitiator.SocketRacer threads and aggregates the results. A socket future is considered fulfilled when...

• any racer thread has established a socket in which case all other racers will be stopped, or
• all racer threads returned with an exception, or
• there was no racer thread (e.g. in case there is no network interface).

In the first case, the socket will be returned. In all other cases, an exception will be thrown, indicating the failure type.

Field Summary

Fields

Modifier and Type	Field	Description
private Exception	mException
private CountDownLatch	mLatch
private List<SocketInitiator.SocketRacer>	mRacers
private Socket	mSocket

Constructor Summary

Constructors

Modifier	Constructor	Description
private	SocketFuture()

Method Summary

Modifier and Type	Method	Description
(package private) Socket	await(List<SocketInitiator.SocketRacer> racers)
(package private) boolean	hasSocket()
(package private) void	setException(Exception exception)
(package private) void	setSocket(SocketInitiator.SocketRacer current, Socket socket)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

mLatch

private CountDownLatch mLatch

mRacers

private List<SocketInitiator.SocketRacer> mRacers

mSocket

private Socket mSocket

mException

private Exception mException

Constructor Details

SocketFuture

private SocketFuture()

Method Details

hasSocket

boolean hasSocket()

setSocket

void setSocket(SocketInitiator.SocketRacer current,
 Socket socket)

setException

void setException(Exception exception)

await

Socket await(List<SocketInitiator.SocketRacer> racers)
      throws Exception

Throws:

Exception