Mercurial > projects > dwt2
view org.eclipse.core.databinding.beans/src/org/eclipse/core/internal/databinding/beans/JavaBeanPropertyObservableMap.d @ 125:c43718956f21 default tip
Updated the snippets status.
author | Jacob Carlborg <doob@me.com> |
---|---|
date | Thu, 11 Aug 2011 19:55:14 +0200 |
parents | 48d4ee626868 |
children |
line wrap: on
line source
/******************************************************************************* * Copyright (c) 2008 Matthew Hall and others. * 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: * Matthew Hall - initial API and implementation (bug 221704) * Matthew Hall - bugs 223164, 244098 *******************************************************************************/ module org.eclipse.core.internal.databinding.beans.JavaBeanPropertyObservableMap; import org.eclipse.core.internal.databinding.beans.ListenerSupport; import java.lang.all; import java.beans.PropertyChangeEvent; import java.beans.PropertyChangeListener; import java.beans.PropertyDescriptor; import java.lang.reflect.InvocationTargetException; import java.lang.reflect.Method; import java.util.Collections; import java.util.HashMap; import java.util.HashSet; import java.util.Iterator; import java.util.Map; import java.util.Set; import org.eclipse.core.databinding.BindingException; import org.eclipse.core.databinding.beans.IBeanObservable; import org.eclipse.core.databinding.observable.Diffs; import org.eclipse.core.databinding.observable.Realm; import org.eclipse.core.databinding.observable.map.ObservableMap; import org.eclipse.core.internal.databinding.Util; import org.eclipse.core.runtime.Assert; /** * @since 1.0 * */ public class JavaBeanPropertyObservableMap : ObservableMap , IBeanObservable { private final Object object; private bool updating = false; private PropertyDescriptor descriptor; private ListenerSupport listenerSupport; /** * @param realm * @param object * @param descriptor */ public this(Realm realm, Object object, PropertyDescriptor descriptor) { this(realm, object, descriptor, true); } /** * @param realm * @param object * @param descriptor * @param attachListeners */ public this(Realm realm, Object object, PropertyDescriptor descriptor, bool attachListeners) { super(realm, new HashMap()); this.object = object; this.descriptor = descriptor; if (attachListeners) { PropertyChangeListener listener = new class() PropertyChangeListener { public void propertyChange(PropertyChangeEvent event) { if (!updating) { getRealm().exec(dgRunnable((PropertyChangeEvent event_) { Map oldValue = wrappedMap; Map newValue = cast(Map) event_.getNewValue(); wrappedMap = new HashMap(newValue); fireMapChange(Diffs.computeMapDiff(oldValue, newValue)); }, event)); } } }; listenerSupport = new ListenerSupport(listener, descriptor.getName()); listenerSupport.hookListener(this.object); } wrappedMap.putAll(getMap()); } private Object primGetMap() { try { Method readMethod = descriptor.getReadMethod(); if (!readMethod.isAccessible()) { readMethod.setAccessible(true); } return readMethod.invoke(object, new Object[0]); } catch (IllegalArgumentException e) { } catch (IllegalAccessException e) { } catch (InvocationTargetException e) { } Assert.isTrue(false, "Could not read collection values"); //$NON-NLS-1$ return null; } private void primSetMap(Object newValue) { Exception ex = null; try { Method writeMethod = descriptor.getWriteMethod(); if (!writeMethod.isAccessible()) { writeMethod.setAccessible(true); } writeMethod.invoke(object, [ newValue ]); return; } catch (IllegalArgumentException e) { ex = e; } catch (IllegalAccessException e) { ex = e; } catch (InvocationTargetException e) { ex = e; } throw new BindingException("Could not write collection values", ex); //$NON-NLS-1$ } private Map getMap() { Map result = cast(Map) primGetMap(); if (result is null) result = new HashMap(); return result; } private void setMap() { primSetMap(new HashMap(wrappedMap)); } public Object put(Object key, Object value) { checkRealm(); updating = true; try { Object result = wrappedMap.put(key, value); if (!Util.equals(result, value)) { setMap(); if (result is null) { fireMapChange(Diffs.createMapDiffSingleAdd(key, value)); } else { fireMapChange(Diffs.createMapDiffSingleChange(key, result, value)); } } return result; } finally { updating = false; } } public void putAll(Map map) { checkRealm(); updating = true; try { Set addedKeys = new HashSet(map.size()); Map changes = new HashMap(map.size()); for (Iterator it = map.entrySet().iterator(); it.hasNext();) { Map.Entry entry = cast(Entry) it.next(); Object key = entry.getKey(); Object newValue = entry.getValue(); Object oldValue = wrappedMap.put(key, newValue); if (oldValue is null) { addedKeys.add(key); } else if (!Util.equals(oldValue, newValue)) { changes.put(key, oldValue); } } if (!addedKeys.isEmpty() || !changes.isEmpty()) { setMap(); fireMapChange(Diffs.createMapDiff(addedKeys, Collections.EMPTY_SET, changes.keySet(), changes, wrappedMap)); } } finally { updating = false; } } public Object remove(Object key) { checkRealm(); updating = true; try { Object result = wrappedMap.remove(key); if (result !is null) { setMap(); fireMapChange(Diffs.createMapDiffSingleRemove(key, result)); } return result; } finally { updating = false; } } public void clear() { checkRealm(); if (wrappedMap.isEmpty()) return; updating = true; try { Map oldMap = wrappedMap; wrappedMap = new HashMap(); setMap(); fireMapChange(Diffs.computeMapDiff(oldMap, Collections.EMPTY_MAP)); } finally { updating = false; } } public Object getObserved() { return object; } public PropertyDescriptor getPropertyDescriptor() { return descriptor; } public synchronized void dispose() { if (listenerSupport !is null) { listenerSupport.dispose(); listenerSupport = null; } super.dispose(); } }