import com.google.common.collect.ImmutableMultimap;
import com.google.common.collect.Lists;
import com.google.common.collect.Multimap;
+import com.google.common.util.concurrent.MoreExecutors;
/**
* A pipeline is responsible for streaming audio data from a {@link Source} to
this.source = source;
this.sinks = sinks;
if (sinks.size() == 1) {
- executorService = Executors.newSingleThreadExecutor();
+ executorService = MoreExecutors.sameThreadExecutor();
} else {
executorService = Executors.newCachedThreadPool();
}
@Override
public void run() {
- Metadata firstMetadata = source.metadata();
+ Metadata firstMetadata = null;
while (!stopped.get()) {
try {
final Metadata lastMetadata = firstMetadata;
} catch (IOException e) {
/* TODO */
e.printStackTrace();
+ break;
} catch (InterruptedException e) {
/* TODO */
e.printStackTrace();
+ break;
} catch (ExecutionException e) {
/* TODO */
e.printStackTrace();
+ break;
}
}
}