X-Git-Url: https://git.pterodactylus.net/?p=sonitus.git;a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fnet%2Fpterodactylus%2Fsonitus%2Fdata%2FPipeline.java;h=66ee2e54df787b6bcf189e9e3c5955861d6b76d5;hp=45d20bf313845264aee913ebd07f65a584491bb7;hb=2503d1e00696c7f4de94482c05b0faea582f42cc;hpb=4cf400fa9e6a9c6c8b1d058a3fa508155ae29d3e

diff --git a/src/main/java/net/pterodactylus/sonitus/data/Pipeline.java b/src/main/java/net/pterodactylus/sonitus/data/Pipeline.java
index 45d20bf..66ee2e5 100644
--- a/src/main/java/net/pterodactylus/sonitus/data/Pipeline.java
+++ b/src/main/java/net/pterodactylus/sonitus/data/Pipeline.java
@@ -347,7 +347,7 @@ public class Pipeline implements Iterable<ControlledComponent> {
 		public Connection(Source source, Collection<Sink> sinks) {
 			this.source = source;
 			this.sinks = sinks;
-			if (sinks.size() == 1) {
+			if (sinks.size() < 2) {
 				executorService = MoreExecutors.sameThreadExecutor();
 			} else {
 				executorService = Executors.newCachedThreadPool();