Thread engineThread = new Thread(
new Runnable() {
public void run() {
+ Transmitter<HedgefishCommand> engineTransmitter = engine.transmitter();
try {
- Transmitter<HedgefishCommand> engineTransmitter = engine.transmitter();
while (engineTransmitter.isActive()) {
if (engineTransmitter.hasCommand()) {
HedgefishCommand command = engineTransmitter.transmitCommand();
CommandDirection.FROM_ENGINE,
null
);
+ engineTransmitter.close();
isRunning = false;
}
}