package rx.broadcast;

import java.util.concurrent.ThreadFactory;
import java.util.concurrent.atomic.AtomicLong;

class DaemonThreadFactory implements ThreadFactory {
    private final AtomicLong id = new AtomicLong();

    @Override
    public final Thread newThread(final Runnable r) {
        final Thread t = new Thread(r);
        t.setDaemon(true);
        t.setName("RxBroadcast-" + id.incrementAndGet());
        return t;
    }
}

@@ -16,16 +16,59 @@
 dcast;%0A%0A
+import org.jetbrains.annotations.NotNull;%0A%0A
 import j
@@ -256,16 +256,29 @@
 ong();%0A%0A
+    @NotNull%0A
     @Ove
@@ -317,16 +317,25 @@
 wThread(
+@NotNull 
 final Ru

Annotate DaemonThreadFactory#newThread as NotNull