@@ -16,7 +16,7 @@ public class TmcEventBus {
1616 public static TmcEventBus getDefault () {
1717 return instance ;
1818 }
19-
19+
2020 // Factory method to avoid accidental creation when getDefault was meant.
2121 public static TmcEventBus createNewInstance () {
2222 return new TmcEventBus ();
@@ -28,22 +28,22 @@ public static TmcEventBus createNewInstance() {
2828 private static interface Wrapper {
2929 public boolean wraps (TmcEventListener that );
3030 }
31-
31+
3232 private static class WeakListener extends TmcEventListener implements Wrapper {
3333 private WeakReference <TmcEventListener > weakRef ;
34-
34+
3535 public WeakListener (TmcEventListener listener ) {
3636 this .weakRef = new WeakReference <TmcEventListener >(listener );
3737 }
38-
38+
3939 @ Override
4040 public void receive (TmcEvent event ) throws Throwable {
4141 TmcEventListener listener = weakRef .get ();
4242 if (listener != null ) {
4343 listener .receive (event );
4444 }
4545 }
46-
46+
4747 @ Override
4848 public boolean mayBeUnsubscribed () {
4949 return weakRef .get () == null ;
@@ -54,16 +54,16 @@ public boolean wraps(TmcEventListener that) {
5454 return that == weakRef .get ();
5555 }
5656 }
57-
57+
5858 private static class DependentListener extends TmcEventListener implements Wrapper {
5959 private TmcEventListener listener ;
6060 private WeakReference <Object > weakRef ;
61-
61+
6262 public DependentListener (TmcEventListener listener , Object dependency ) {
6363 this .listener = listener ;
6464 this .weakRef = new WeakReference <Object >(dependency );
6565 }
66-
66+
6767 @ Override
6868 public void receive (TmcEvent event ) throws Throwable {
6969 listener .receive (event );
@@ -91,15 +91,15 @@ private TmcEventBus() {
9191 public synchronized void subscribeStrongly (TmcEventListener listener ) {
9292 this .listeners .add (listener );
9393 }
94-
94+
9595 /**
9696 * Subscribes a weak reference to a listener.
9797 * After all normal references to the listener disappear, it will eventually be unsubscribed.
9898 */
9999 public synchronized void subscribeWeakly (TmcEventListener listener ) {
100100 this .listeners .add (new WeakListener (listener ));
101101 }
102-
102+
103103 /**
104104 * Subscribes a listener that is eventually removed after a given dependency is garbage-collected.
105105 */
@@ -125,7 +125,7 @@ public synchronized void post(TmcEvent event) {
125125 eventQueue .add (event );
126126 processEventQueue ();
127127 }
128-
128+
129129 private void processEventQueue () {
130130 // This handles post() during post()
131131 // but not yet subscribe*() during post().
0 commit comments