sk.stuba.fiit.perconik.core.services

Class ServiceGroup<S extends Service>

java.lang.Object

com.google.common.collect.ForwardingObject

com.google.common.collect.ForwardingCollection<E>

com.google.common.collect.ForwardingSet<S>

sk.stuba.fiit.perconik.core.services.ServiceGroup<S>

Type Parameters:

S - the common supertype that all services must share

All Implemented Interfaces:

java.lang.Iterable<S>, java.util.Collection<S>, java.util.Set<S>

public final class ServiceGroup<S extends Service>
extends com.google.common.collect.ForwardingSet<S>

An immutable set of Service instances user-specified iteration order. Does not permit null elements.

Since:

1.0

Author:

Pavol Zbell

Method Summary

Modifier and Type	Method and Description
protected java.util.Set<S>	delegate()
<U extends S> U	fetch(java.lang.Class<U> type)
<U extends S> ServiceGroup<U>	narrow(java.lang.Class<U> type)
static <S extends Service> ServiceGroup<S>	of() Returns the empty service group.
static <S extends Service> ServiceGroup<S>	of(S service) Returns a service group containing a single service.
static <S extends Service> ServiceGroup<S>	of(S first, S second) Returns a service group containing the given services, in order.
static <S extends Service> ServiceGroup<S>	of(S first, S second, S... rest) Returns a service group containing the given services, in order.
ServiceGroup<S>	reverse()
void	startSynchronously()
void	startSynchronously(long timeout, java.util.concurrent.TimeUnit unit)
void	startSynchronously(TimeValue timeout)
java.util.Map<S,com.google.common.util.concurrent.Service.State>	states()
void	stopSynchronously()
void	stopSynchronously(long timeout, java.util.concurrent.TimeUnit unit)
void	stopSynchronously(TimeValue timeout)

Methods inherited from class com.google.common.collect.ForwardingSet

equals, hashCode, standardEquals, standardHashCode, standardRemoveAll

Methods inherited from class com.google.common.collect.ForwardingCollection

add, addAll, clear, contains, containsAll, isEmpty, iterator, remove, removeAll, retainAll, size, standardAddAll, standardClear, standardContains, standardContainsAll, standardIsEmpty, standardRemove, standardRetainAll, standardToArray, standardToArray, standardToString, toArray, toArray

Methods inherited from class com.google.common.collect.ForwardingObject

toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.util.Set

add, addAll, clear, contains, containsAll, isEmpty, iterator, remove, removeAll, retainAll, size, spliterator, toArray, toArray

Methods inherited from interface java.util.Collection

parallelStream, removeIf, stream

Methods inherited from interface java.lang.Iterable

forEach

Method Detail

of

public static <S extends Service> ServiceGroup<S> of()

Returns the empty service group.

of

public static <S extends Service> ServiceGroup<S> of(S service)

Returns a service group containing a single service.

of

public static <S extends Service> ServiceGroup<S> of(S first,
                                                     S second)

Returns a service group containing the given services, in order. Repeated occurrences of a service (according to Object.equals(java.lang.Object)) after the first are ignored.

Throws:

java.lang.NullPointerException - if any service is null

of

@SafeVarargs
public static <S extends Service> ServiceGroup<S> of(S first,
                                                                  S second,
                                                                  S... rest)

Returns a service group containing the given services, in order. Repeated occurrences of a service (according to Object.equals(java.lang.Object)) after the first are ignored.

Throws:

java.lang.NullPointerException - if any service is null

delegate

protected java.util.Set<S> delegate()

Overrides:

delegate in class com.google.common.collect.ForwardingSet<S extends Service>

startSynchronously

public void startSynchronously()

startSynchronously

public void startSynchronously(long timeout,
                               java.util.concurrent.TimeUnit unit)
                        throws java.util.concurrent.TimeoutException

Throws:

java.util.concurrent.TimeoutException

startSynchronously

public void startSynchronously(TimeValue timeout)
                        throws java.util.concurrent.TimeoutException

Throws:

java.util.concurrent.TimeoutException

stopSynchronously

public void stopSynchronously()

stopSynchronously

public void stopSynchronously(long timeout,
                              java.util.concurrent.TimeUnit unit)
                       throws java.util.concurrent.TimeoutException

Throws:

java.util.concurrent.TimeoutException

stopSynchronously

public void stopSynchronously(TimeValue timeout)
                       throws java.util.concurrent.TimeoutException

Throws:

java.util.concurrent.TimeoutException

states

public java.util.Map<S,com.google.common.util.concurrent.Service.State> states()

narrow

public <U extends S> ServiceGroup<U> narrow(java.lang.Class<U> type)

fetch

public <U extends S> U fetch(java.lang.Class<U> type)

reverse

public ServiceGroup<S> reverse()