|
@@ -24,7 +24,7 @@ public class ObserverDispatch {
|
|
|
Multimap<UUID, Pair> observers = LinkedListMultimap.create();
|
|
Multimap<UUID, Pair> observers = LinkedListMultimap.create();
|
|
|
|
|
|
|
|
public void subscribe(Observable target, Object src, Subscriber sub) {
|
|
public void subscribe(Observable target, Object src, Subscriber sub) {
|
|
|
- observers.put(target.getObservableId(), new Pair(new WeakReference<>(src), sub));
|
|
|
|
|
|
|
+ observers.put(target.observableId(), new Pair(new WeakReference<>(src), sub));
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
public void unsubscribeAll(Object src) {
|
|
public void unsubscribeAll(Object src) {
|
|
@@ -33,11 +33,11 @@ public class ObserverDispatch {
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
void notifySubscribers(Observable target, IndirectObservableListener<?, ?> src) {
|
|
void notifySubscribers(Observable target, IndirectObservableListener<?, ?> src) {
|
|
|
- observers.get(target.getObservableId()).stream().filter(
|
|
|
|
|
|
|
+ observers.get(target.observableId()).stream().filter(
|
|
|
p -> p.obj.get() != src).forEach( p -> p.sub.notifyUpdate() );
|
|
p -> p.obj.get() != src).forEach( p -> p.sub.notifyUpdate() );
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
public void notifySubscribers(Observable target) {
|
|
public void notifySubscribers(Observable target) {
|
|
|
- observers.get(target.getObservableId()).stream().forEach( p -> p.sub.notifyUpdate() );
|
|
|
|
|
|
|
+ observers.get(target.observableId()).stream().forEach( p -> p.sub.notifyUpdate() );
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|