public interface TeammateCommandExecutorService
Modifier and Type | Interface and Description |
---|---|
static class |
TeammateCommandExecutorService.CancellationCause
Cancellation cause.
|
static interface |
TeammateCommandExecutorService.Command<R,I,T extends Addressable<IpAddress>>
Command.
|
static interface |
TeammateCommandExecutorService.CommandListener<R,T extends Addressable<IpAddress>>
Command listener.
|
Modifier and Type | Method and Description |
---|---|
<R,I> Collection<Pair<SystemInformation,Result<R,Exception,TeammateCommandExecutorService.CancellationCause>>> |
execute(TeammateCommandExecutorService.Command<R,I,SystemInformation> command,
I input)
Executes a command across the team (After a team has been created).
|
<R,I> void |
execute(TeammateCommandExecutorService.Command<R,I,SystemInformation> command,
I input,
TeammateCommandExecutorService.CommandListener<R,SystemInformation> listener)
Executes a command across the team (After a team has been created).
|
<R,I,T extends Addressable<IpAddress>> |
execute(TeammateCommandExecutorService.Command<R,I,T> command,
I input,
Collection<T> teammates)
Executes a command across a potential team (Before the team has been
created).
|
<R,I,T extends Addressable<IpAddress>> |
execute(TeammateCommandExecutorService.Command<R,I,T> command,
I input,
Collection<T> teammates,
TeammateCommandExecutorService.CommandListener<R,T> listener)
Executes a command across a potential team (Before the team has been
created).
|
<R,I> Collection<Pair<SystemInformation,Result<R,Exception,TeammateCommandExecutorService.CancellationCause>>> execute(TeammateCommandExecutorService.Command<R,I,SystemInformation> command, I input)
input
must be immutable.
This call is synchronous, so it will block until the execution is completed in all team mates.
command
- command to execute.input
- command's input.<R,I,T extends Addressable<IpAddress>> Collection<Pair<T,Result<R,Exception,TeammateCommandExecutorService.CancellationCause>>> execute(TeammateCommandExecutorService.Command<R,I,T> command, I input, Collection<T> teammates)
input
must be
immutable.
This call is synchronous, so it will block until the execution is completed in all team mates.
command
- command to execute.input
- command's input.teammates
- future teammates.<R,I> void execute(TeammateCommandExecutorService.Command<R,I,SystemInformation> command, I input, TeammateCommandExecutorService.CommandListener<R,SystemInformation> listener)
input
must be immutable.
This call is asynchronous; the provided listener
will be
notified as commands are being processed.
command
- command to execute.input
- command's input.listener
- command listener.<R,I,T extends Addressable<IpAddress>> void execute(TeammateCommandExecutorService.Command<R,I,T> command, I input, Collection<T> teammates, TeammateCommandExecutorService.CommandListener<R,T> listener)
input
must be
immutable.
This call is asynchronous; the provided listener
will be
notified as commands are being processed.
command
- command to execute.input
- command's input.teammates
- future teammates.listener
- command listener.Copyright © 2015. All Rights Reserved.