same/src/test/java/com/orbekk/net/BroadcastListenerTest.java


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32

package com.orbekk.net;

import static org.junit.Assert.*;

import org.junit.Test;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class BroadcastListenerTest {
    private Logger logger = LoggerFactory.getLogger(getClass());
    
    @Test
    public void interruptWorks() throws Exception {
        final BroadcastListener listener = new BroadcastListener(0);

        Thread t = new Thread() {
            @Override public void run() {
                listener.listen();
            }
        };
        t.start();
        
        while (listener.socket == null) {
            logger.info("Waiting for listener to start.");
            Thread.sleep(100);
        }
        
        listener.interrupt();
        t.join();
    }

}