git://wamblee.org
/
utils
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Removed DOCUMENT ME comments that were generated and applied source code
[utils]
/
support
/
general
/
src
/
main
/
java
/
org
/
wamblee
/
observer
/
Observable.java
diff --git
a/support/general/src/main/java/org/wamblee/observer/Observable.java
b/support/general/src/main/java/org/wamblee/observer/Observable.java
index 096b0600043f726d9bdc493f83d3aacbe2e19d78..219c51fcee04d8adcae19c249b0eaaa423b648f0 100644
(file)
--- a/
support/general/src/main/java/org/wamblee/observer/Observable.java
+++ b/
support/general/src/main/java/org/wamblee/observer/Observable.java
@@
-22,7
+22,6
@@
import java.util.List;
import java.util.Map;
import java.util.TreeMap;
import java.util.Map;
import java.util.TreeMap;
-
/**
* Implements subscription and notification logic for an observer pattern. This
* class is thread safe.
/**
* Implements subscription and notification logic for an observer pattern. This
* class is thread safe.
@@
-52,7
+51,7
@@
public class Observable<ObservableType, Event> {
/**
* Constructs the observable.
/**
* Constructs the observable.
- *
+ *
* @param aObservable
* Observable this instance is used for.
* @param aNotifier
* @param aObservable
* Observable this instance is used for.
* @param aNotifier
@@
-68,15
+67,14
@@
public class Observable<ObservableType, Event> {
/**
* Subscribe an obvers.
/**
* Subscribe an obvers.
- *
+ *
* @param aObserver
* Observer to subscribe.
* @return Event Event to send.
*/
* @param aObserver
* Observer to subscribe.
* @return Event Event to send.
*/
- public synchronized long subscribe(
- Observer<ObservableType, Event> aObserver) {
+ public synchronized long subscribe(Observer<ObservableType, Event> aObserver) {
long subscription = counter++; // integer rage is so large it will
long subscription = counter++; // integer rage is so large it will
-
// never roll over.
+ // never roll over.
observers.put(subscription, aObserver);
observers.put(subscription, aObserver);
@@
-85,7
+83,7
@@
public class Observable<ObservableType, Event> {
/**
* Unsubscribe an observer.
/**
* Unsubscribe an observer.
- *
+ *
* @param aSubscription
* Subscription which is used
* @throws IllegalArgumentException
* @param aSubscription
* Subscription which is used
* @throws IllegalArgumentException
@@
-102,7
+100,7
@@
public class Observable<ObservableType, Event> {
/**
* Gets the number of subscribed observers.
/**
* Gets the number of subscribed observers.
- *
+ *
* @return Number of subscribed observers.
*/
public int getObserverCount() {
* @return Number of subscribed observers.
*/
public int getObserverCount() {
@@
-111,7
+109,7
@@
public class Observable<ObservableType, Event> {
/**
* Notifies all subscribed observers.
/**
* Notifies all subscribed observers.
- *
+ *
* @param aEvent
* Event to send.
*/
* @param aEvent
* Event to send.
*/
@@
-132,14
+130,14
@@
public class Observable<ObservableType, Event> {
/*
* (non-Javadoc)
/*
* (non-Javadoc)
- *
+ *
* @see java.lang.Object#finalize()
*/
@Override
protected void finalize() throws Throwable {
if (observers.size() > 0) {
* @see java.lang.Object#finalize()
*/
@Override
protected void finalize() throws Throwable {
if (observers.size() > 0) {
- LOGGER
.error(
- "Still observers registered at finalization of observer!");
+ LOGGER
+
.error(
"Still observers registered at finalization of observer!");
for (Observer observer : observers.values()) {
LOGGER.error(" observer: " + observer);
for (Observer observer : observers.values()) {
LOGGER.error(" observer: " + observer);