@@ -0,0 +1,439 @@
+package rx.broadcast;%0A%0Aimport java.util.concurrent.ThreadFactory;%0Aimport java.util.concurrent.atomic.AtomicLong;%0A%0Aclass DaemonThreadFactory implements ThreadFactory %7B%0A    private final AtomicLong id = new AtomicLong();%0A%0A    @Override%0A    public final Thread newThread(final Runnable r) %7B%0A        final Thread t = new Thread(r);%0A        t.setDaemon(true);%0A        t.setName(%22RxBroadcast-%22 + id.incrementAndGet());%0A        return t;%0A    %7D%0A%7D%0A

Add DaemonThreadFactory for daemon threads