litesoft
Subversion Repository Public Repository

litesoft

URLs

Copy to Clipboard
Explore
Commits

Diff Revisions 947 vs 948 for /trunk/Java/GWT/OldClient/src/org/litesoft/GWT/eventbus/client/nonpublic/SubscriptionManager.java

Diff revisions: vs.
  @@ -1,64 +1,53 @@
1 1 // This Source Code is in the Public Domain per: http://unlicense.org
2 2 package org.litesoft.GWT.eventbus.client.nonpublic;
3 3
4 - import java.util.*;
5 -
6 4 import org.litesoft.GWT.eventbus.client.*;
7 5
8 - public class SubscriptionManager
9 - {
6 + import java.util.*;
7 +
8 + public class SubscriptionManager {
10 9 private Map mSubscribers = new HashMap(); // TargetName to ListenersEntry
11 10 private String mEBform;
12 11
13 - public SubscriptionManager( String pEBform )
14 - {
12 + public SubscriptionManager( String pEBform ) {
15 13 mEBform = pEBform;
16 14 }
17 15
18 - public synchronized void clear()
19 - {
16 + public synchronized void clear() {
20 17 mSubscribers.clear();
21 18 }
22 19
23 - public synchronized boolean anySubscribers( String pTargetName )
24 - {
20 + public synchronized boolean anySubscribers( String pTargetName ) {
25 21 return (null != getListenersEntry( pTargetName ));
26 22 }
27 23
28 - public synchronized boolean hasPeerAcknowledged( String pTargetName )
29 - {
24 + public synchronized boolean hasPeerAcknowledged( String pTargetName ) {
30 25 ListenersEntry entry = getListenersEntry( pTargetName );
31 26 return (entry != null) && entry.hasPeerAcknowledged();
32 27 }
33 28
34 - public synchronized void setPeerAcknowledged( String pTargetName )
35 - {
29 + public synchronized void setPeerAcknowledged( String pTargetName ) {
36 30 ListenersEntry entry = getListenersEntry( pTargetName );
37 - if ( entry != null )
38 - {
31 + if ( entry != null ) {
39 32 entry.setPeerAcknowledged();
40 33 }
41 34 }
42 35
43 - public synchronized EventPackageListener[] getListenersFor( String pTargetName )
44 - {
36 + public synchronized EventPackageListener[] getListenersFor( String pTargetName ) {
45 37 ListenersEntry entry = getListenersEntry( pTargetName );
46 38 return (entry != null) ? entry.getListeners() : null;
47 39 }
48 40
49 - private ListenersEntry getListenersEntry( String pTargetName )
50 - {
41 + private ListenersEntry getListenersEntry( String pTargetName ) {
51 42 return (ListenersEntry) mSubscribers.get( pTargetName );
52 43 }
53 44
54 45 /**
55 46 * @return T/F if added first pListener for pTargetName
56 47 */
57 - public synchronized boolean subscribe( String pTargetName, EventPackageListener pListener )
58 - {
48 + public synchronized boolean subscribe( String pTargetName, EventPackageListener pListener ) {
59 49 ListenersEntry entry = getListenersEntry( pTargetName );
60 - if ( entry == null )
61 - {
50 + if ( entry == null ) {
62 51 mSubscribers.put( pTargetName, new ListenersEntry( pListener ) );
63 52 return true; // Just Added first Listener for TargetName
64 53 }
  @@ -69,13 +58,10 @@
69 58 /**
70 59 * @return T/F if removed last pListener for pTargetName
71 60 */
72 - public synchronized boolean unsubscribe( String pTargetName, EventPackageListener pListener )
73 - {
61 + public synchronized boolean unsubscribe( String pTargetName, EventPackageListener pListener ) {
74 62 ListenersEntry entry = getListenersEntry( pTargetName );
75 - if ( entry != null )
76 - {
77 - if ( entry.remove( pListener ) )
78 - {
63 + if ( entry != null ) {
64 + if ( entry.remove( pListener ) ) {
79 65 mSubscribers.remove( pTargetName );
80 66 return true; // reduced to nothing
81 67 }
  @@ -83,47 +69,38 @@
83 69 return false;
84 70 }
85 71
86 - public String toString()
87 - {
72 + public String toString() {
88 73 return mEBform;
89 74 }
90 75
91 - private static class ListenersEntry
92 - {
76 + private static class ListenersEntry {
93 77 private EventPackageListener[] mListeners;
94 78 private boolean mPeerAcknowledged = false;
95 79
96 - public ListenersEntry( EventPackageListener pListener )
97 - {
80 + public ListenersEntry( EventPackageListener pListener ) {
98 81 mListeners = new EventPackageListener[]{pListener};
99 82 }
100 83
101 - public EventPackageListener[] getListeners()
102 - {
84 + public EventPackageListener[] getListeners() {
103 85 return mListeners;
104 86 }
105 87
106 - public boolean hasPeerAcknowledged()
107 - {
88 + public boolean hasPeerAcknowledged() {
108 89 return mPeerAcknowledged;
109 90 }
110 91
111 - public void setPeerAcknowledged()
112 - {
92 + public void setPeerAcknowledged() {
113 93 mPeerAcknowledged = true;
114 94 }
115 95
116 96 /**
117 97 * @return T/F if pListener added (not already in the list)
118 98 */
119 - public boolean add( EventPackageListener pListener )
120 - {
99 + public boolean add( EventPackageListener pListener ) {
121 100 EventPackageListener[] newListeners = new EventPackageListener[mListeners.length + 1];
122 101 int i = 0;
123 - for ( ; i < mListeners.length; i++ )
124 - {
125 - if ( pListener == (newListeners[i] = mListeners[i]) )
126 - {
102 + for (; i < mListeners.length; i++ ) {
103 + if ( pListener == (newListeners[i] = mListeners[i]) ) {
127 104 return false;
128 105 }
129 106 }
  @@ -135,34 +112,27 @@
135 112 /**
136 113 * @return T/F if would have reduced to NO listeners
137 114 */
138 - public boolean remove( EventPackageListener pListener )
139 - {
115 + public boolean remove( EventPackageListener pListener ) {
140 116 int at = -1;
141 - for ( int i = 0; i < mListeners.length; i++ )
142 - {
143 - if ( pListener == mListeners[i] )
144 - {
117 + for ( int i = 0; i < mListeners.length; i++ ) {
118 + if ( pListener == mListeners[i] ) {
145 119 at = i;
146 120 break;
147 121 }
148 122 }
149 - if ( at == -1 )
150 - {
123 + if ( at == -1 ) {
151 124 return false;
152 125 }
153 - if ( mListeners.length == 1 )
154 - {
126 + if ( mListeners.length == 1 ) {
155 127 return true; // reduced to nothing
156 128 }
157 129 EventPackageListener[] newListeners = new EventPackageListener[mListeners.length - 1];
158 130 int from = 0, to = 0;
159 - while ( from < at )
160 - {
131 + while ( from < at ) {
161 132 newListeners[to++] = mListeners[from++];
162 133 }
163 134 from++;
164 - while ( from < mListeners.length )
165 - {
135 + while ( from < mListeners.length ) {
166 136 newListeners[to++] = mListeners[from++];
167 137 }
168 138 mListeners = newListeners;

View View this file contents

History View the full history

Feeds

Commits for /trunk/Java/GWT/OldClient/src/org/litesoft/GWT/eventbus/client/nonpublic/SubscriptionManager.java

Need assistance?   Get in touch, or head to our documentation site.