@@ -16,7 +16,7 @@ public class TmcEventBus {
16
16
public static TmcEventBus getDefault () {
17
17
return instance ;
18
18
}
19
-
19
+
20
20
// Factory method to avoid accidental creation when getDefault was meant.
21
21
public static TmcEventBus createNewInstance () {
22
22
return new TmcEventBus ();
@@ -28,22 +28,22 @@ public static TmcEventBus createNewInstance() {
28
28
private static interface Wrapper {
29
29
public boolean wraps (TmcEventListener that );
30
30
}
31
-
31
+
32
32
private static class WeakListener extends TmcEventListener implements Wrapper {
33
33
private WeakReference <TmcEventListener > weakRef ;
34
-
34
+
35
35
public WeakListener (TmcEventListener listener ) {
36
36
this .weakRef = new WeakReference <TmcEventListener >(listener );
37
37
}
38
-
38
+
39
39
@ Override
40
40
public void receive (TmcEvent event ) throws Throwable {
41
41
TmcEventListener listener = weakRef .get ();
42
42
if (listener != null ) {
43
43
listener .receive (event );
44
44
}
45
45
}
46
-
46
+
47
47
@ Override
48
48
public boolean mayBeUnsubscribed () {
49
49
return weakRef .get () == null ;
@@ -54,16 +54,16 @@ public boolean wraps(TmcEventListener that) {
54
54
return that == weakRef .get ();
55
55
}
56
56
}
57
-
57
+
58
58
private static class DependentListener extends TmcEventListener implements Wrapper {
59
59
private TmcEventListener listener ;
60
60
private WeakReference <Object > weakRef ;
61
-
61
+
62
62
public DependentListener (TmcEventListener listener , Object dependency ) {
63
63
this .listener = listener ;
64
64
this .weakRef = new WeakReference <Object >(dependency );
65
65
}
66
-
66
+
67
67
@ Override
68
68
public void receive (TmcEvent event ) throws Throwable {
69
69
listener .receive (event );
@@ -91,15 +91,15 @@ private TmcEventBus() {
91
91
public synchronized void subscribeStrongly (TmcEventListener listener ) {
92
92
this .listeners .add (listener );
93
93
}
94
-
94
+
95
95
/**
96
96
* Subscribes a weak reference to a listener.
97
97
* After all normal references to the listener disappear, it will eventually be unsubscribed.
98
98
*/
99
99
public synchronized void subscribeWeakly (TmcEventListener listener ) {
100
100
this .listeners .add (new WeakListener (listener ));
101
101
}
102
-
102
+
103
103
/**
104
104
* Subscribes a listener that is eventually removed after a given dependency is garbage-collected.
105
105
*/
@@ -125,7 +125,7 @@ public synchronized void post(TmcEvent event) {
125
125
eventQueue .add (event );
126
126
processEventQueue ();
127
127
}
128
-
128
+
129
129
private void processEventQueue () {
130
130
// This handles post() during post()
131
131
// but not yet subscribe*() during post().
0 commit comments