|
@@ -25,23 +25,14 @@ import com.dmdirc.events.DisplayProperty;
|
25
|
25
|
import com.dmdirc.events.DisplayableEvent;
|
26
|
26
|
import com.dmdirc.events.QueryHighlightEvent;
|
27
|
27
|
import com.dmdirc.events.UnreadStatusChangedEvent;
|
28
|
|
-import com.dmdirc.events.eventbus.EventBus;
|
29
|
28
|
import com.dmdirc.interfaces.WindowModel;
|
30
|
29
|
import com.dmdirc.util.colours.Colour;
|
31
|
|
-
|
32
|
|
-import java.util.Optional;
|
33
|
|
-import java.util.concurrent.TimeUnit;
|
34
|
|
-
|
35
|
|
-import io.reactivex.Emitter;
|
36
|
|
-import io.reactivex.Observable;
|
37
|
|
-import io.reactivex.ObservableEmitter;
|
38
|
|
-import io.reactivex.Observer;
|
39
|
|
-import io.reactivex.functions.Consumer;
|
40
|
30
|
import io.reactivex.subjects.PublishSubject;
|
41
|
|
-import io.reactivex.subjects.ReplaySubject;
|
42
|
31
|
import io.reactivex.subjects.Subject;
|
43
|
32
|
import net.engio.mbassy.listener.Handler;
|
44
|
|
-import org.reactivestreams.Publisher;
|
|
33
|
+
|
|
34
|
+import java.util.Optional;
|
|
35
|
+import java.util.concurrent.TimeUnit;
|
45
|
36
|
|
46
|
37
|
/**
|
47
|
38
|
* Tracks unread messages and other notifications.
|