summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--same/src/main/java/com/orbekk/same/BroadcasterImpl.java7
1 files changed, 4 insertions, 3 deletions
diff --git a/same/src/main/java/com/orbekk/same/BroadcasterImpl.java b/same/src/main/java/com/orbekk/same/BroadcasterImpl.java
index 688a388..9ad7296 100644
--- a/same/src/main/java/com/orbekk/same/BroadcasterImpl.java
+++ b/same/src/main/java/com/orbekk/same/BroadcasterImpl.java
@@ -4,16 +4,17 @@ import java.util.List;
import java.util.concurrent.Executor;
import java.util.concurrent.Executors;
-public class BroadcasterImpl {
+public class BroadcasterImpl implements Broadcaster {
private ConnectionManager connections;
private Executor executor;
/**
* Get a BroadcastRunner for ClientService using a thread pool of size 20.
*/
- public static BroadcasterImpl getDefaultBroadcastRunner() {
+ public static BroadcasterImpl getDefaultBroadcastRunner(
+ ConnectionManager connections) {
return new BroadcasterImpl(Executors.newFixedThreadPool(20),
- new ConnectionManagerImpl());
+ connections);
}
public BroadcasterImpl(Executor executor,