-/*******************************************************************************\r
- * Copyright (c) 2007, 2010 Association for Decentralized Information Management\r
- * in Industry THTH ry.\r
- * All rights reserved. This program and the accompanying materials\r
- * are made available under the terms of the Eclipse Public License v1.0\r
- * which accompanies this distribution, and is available at\r
- * http://www.eclipse.org/legal/epl-v10.html\r
- *\r
- * Contributors:\r
- * VTT Technical Research Centre of Finland - initial API and implementation\r
- *******************************************************************************/\r
-package org.simantics.scenegraph.profile.common;\r
-\r
-import java.util.Map;\r
-import java.util.Set;\r
-import java.util.concurrent.ConcurrentHashMap;\r
-\r
-import org.simantics.db.Resource;\r
-import org.simantics.db.procedure.SetListener;\r
-import org.simantics.scenegraph.profile.Group;\r
-import org.simantics.scenegraph.profile.Observer;\r
-import org.simantics.scenegraph.profile.Style;\r
-\r
-public class ObserverGroupListener implements SetListener<Resource> {\r
-\r
- final Map<Object, Object> items = new ConcurrentHashMap<Object, Object>();\r
- final Map<Resource, Resource> entries = new ConcurrentHashMap<Resource, Resource>();\r
-\r
- protected final Style style;\r
- protected final Group group;\r
- protected final Observer observer;\r
- private boolean disposed = false;\r
-\r
- public ObserverGroupListener(Style style, Group group, Observer observer) {\r
- assert(style != null);\r
- assert(group != null);\r
- assert(observer != null);\r
- this.style = style;\r
- this.group = group;\r
- this.observer = observer;\r
- }\r
-\r
- @Override\r
- public void add(Resource item) {\r
- //System.out.println("Add to group(" + this + "): " + item);\r
- items.put(item, item);\r
- observer.update();\r
- }\r
-\r
- @Override\r
- public void remove(Resource item) {\r
-// new Exception().printStackTrace();\r
- //System.out.println("Remove from group(" + this + "): " + item);\r
- items.remove(item);\r
- observer.update();\r
- }\r
-\r
- @Override\r
- public int hashCode() {\r
- return observer.hashCode() + 31 * group.hashCode() + 41 * style.hashCode();\r
- }\r
-\r
- @Override\r
- public boolean equals(Object object) {\r
- if (this == object)\r
- return true;\r
- else if (object == null)\r
- return false;\r
- else if (ObserverGroupListener.class != object.getClass())\r
- return false;\r
- ObserverGroupListener other = (ObserverGroupListener)object;\r
- return observer.equals(other.observer) && group.equals(other.group) && style.equals(other.style);\r
- }\r
-\r
- public Set<Object> getItems() {\r
- return items.keySet();\r
- }\r
-\r
- public void dispose() {\r
- this.disposed = true;\r
- }\r
-\r
- @Override\r
- public boolean isDisposed() {\r
- return disposed || observer.isDisposed();\r
- }\r
-\r
- @Override\r
- public void exception(Throwable throwable) {\r
- observer.exception(throwable);\r
- }\r
-\r
- public void addEntry(Resource entry) {\r
- entries.put(entry, entry);\r
- }\r
-\r
- public void removeEntry(Resource entry) {\r
- entries.remove(entry);\r
- }\r
-\r
- public boolean hasEntries() {\r
- return !entries.isEmpty();\r
- }\r
-\r
-}\r
+/*******************************************************************************
+ * Copyright (c) 2007, 2010 Association for Decentralized Information Management
+ * in Industry THTH ry.
+ * All rights reserved. This program and the accompanying materials
+ * are made available under the terms of the Eclipse Public License v1.0
+ * which accompanies this distribution, and is available at
+ * http://www.eclipse.org/legal/epl-v10.html
+ *
+ * Contributors:
+ * VTT Technical Research Centre of Finland - initial API and implementation
+ *******************************************************************************/
+package org.simantics.scenegraph.profile.common;
+
+import java.util.Map;
+import java.util.Set;
+import java.util.concurrent.ConcurrentHashMap;
+
+import org.simantics.db.Resource;
+import org.simantics.db.procedure.SetListener;
+import org.simantics.scenegraph.profile.Group;
+import org.simantics.scenegraph.profile.Observer;
+import org.simantics.scenegraph.profile.Style;
+
+public class ObserverGroupListener implements SetListener<Resource> {
+
+ final Map<Object, Object> items = new ConcurrentHashMap<Object, Object>();
+ final Map<Resource, Resource> entries = new ConcurrentHashMap<Resource, Resource>();
+
+ protected final Style style;
+ protected final Group group;
+ protected final Observer observer;
+ private boolean disposed = false;
+
+ public ObserverGroupListener(Style style, Group group, Observer observer) {
+ assert(style != null);
+ assert(group != null);
+ assert(observer != null);
+ this.style = style;
+ this.group = group;
+ this.observer = observer;
+ }
+
+ @Override
+ public void add(Resource item) {
+ //System.out.println("Add to group(" + this + "): " + item);
+ items.put(item, item);
+ observer.update(style, item);
+ }
+
+ @Override
+ public void remove(Resource item) {
+// new Exception().printStackTrace();
+ //System.out.println("Remove from group(" + this + "): " + item);
+ items.remove(item);
+ observer.update(style, item);
+ }
+
+ @Override
+ public int hashCode() {
+ return observer.hashCode() + 31 * group.hashCode() + 41 * style.hashCode();
+ }
+
+ @Override
+ public boolean equals(Object object) {
+ if (this == object)
+ return true;
+ else if (object == null)
+ return false;
+ else if (getClass() != object.getClass())
+ return false;
+ ObserverGroupListener other = (ObserverGroupListener)object;
+ return observer.equals(other.observer) && group.equals(other.group) && style.equals(other.style);
+ }
+
+ public Set<Object> getItems() {
+ return items.keySet();
+ }
+
+ public void dispose() {
+ this.disposed = true;
+ }
+
+ @Override
+ public boolean isDisposed() {
+ return disposed || observer.isDisposed();
+ }
+
+ @Override
+ public void exception(Throwable throwable) {
+ observer.exception(throwable);
+ }
+
+ public void addEntry(Resource entry) {
+ entries.put(entry, entry);
+ }
+
+ public void removeEntry(Resource entry) {
+ entries.remove(entry);
+ }
+
+ public boolean hasEntries() {
+ return !entries.isEmpty();
+ }
+
+}
Code Review / simantics / platform.git / blobdiff