same/src/test/java/com/orbekk/same/TestBroadcaster.java


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

package com.orbekk.same;

import java.util.List;

public class TestBroadcaster implements Broadcaster {
    private ConnectionManager connections;

    public TestBroadcaster(ConnectionManager connections) {
        this.connections = connections;
    }

    public void broadcast(final  List<String> targets,
            final ServiceOperation operation) {
        for (String t : targets) {
            ClientService client = connections.getClient(t);
            operation.run(client);
        }
    }
}