From: David ‘Bombe’ Roden Date: Thu, 6 Jun 2013 04:36:10 +0000 (+0200) Subject: Create a simpler thread name because we only have one sink per filter. X-Git-Url: https://git.pterodactylus.net/?a=commitdiff_plain;h=504b31b4b9b83454459e06999449d02b92b11b2a;p=sonitus.git Create a simpler thread name because we only have one sink per filter. --- diff --git a/src/main/java/net/pterodactylus/sonitus/data/filter/PipelineFilter.java b/src/main/java/net/pterodactylus/sonitus/data/filter/PipelineFilter.java index 59e34be..492db5b 100644 --- a/src/main/java/net/pterodactylus/sonitus/data/filter/PipelineFilter.java +++ b/src/main/java/net/pterodactylus/sonitus/data/filter/PipelineFilter.java @@ -28,8 +28,6 @@ import net.pterodactylus.sonitus.data.Filter; import net.pterodactylus.sonitus.data.Metadata; import net.pterodactylus.sonitus.data.Pipeline.Connection; -import com.google.common.base.Function; -import com.google.common.collect.FluentIterable; import com.google.common.collect.Lists; /** @@ -84,13 +82,7 @@ public class PipelineFilter extends AbstractFilter implements Filter { filter.open(currentMetadata); currentMetadata = filter.metadata(); Connection connection = new Connection(currentSource, Arrays.asList(filter)); - String threadName = String.format("%s → %s.", connection.source().name(), FluentIterable.from(connection.sinks()).transform(new Function() { - - @Override - public String apply(Filter sink) { - return sink.name(); - } - })); + String threadName = String.format("%s → %s", connection.source().name(), filter.name()); new Thread(connection, threadName).start(); currentSource = filter; }