import org.eclipse.core.databinding.observable.set.IObservableSet; //导入依赖的package包/类
protected void removeSource ( final IObservableSet observableSet )
{
    if ( observableSet == null )
    {
        return;
    }

    for ( final Iterator<?> it = observableSet.iterator (); it.hasNext (); )
    {
        removeListenerFrom ( it.next () );
    }
    observableSet.removeSetChangeListener ( this.listener );

    if ( !this.disposed )
    {
        this.sources.remove ( observableSet );
    }
}
 

import org.eclipse.core.databinding.observable.set.IObservableSet; //导入依赖的package包/类
@Override
public void dispose ()
{
    if ( this.disposed )
    {
        return;
    }

    this.disposed = true;

    for ( final IObservableSet set : this.sources )
    {
        if ( !set.isDisposed () )
        {
            for ( final Iterator<?> iter = set.iterator (); iter.hasNext (); )
            {
                removeListenerFrom ( iter.next () );
            }
        }
        set.removeSetChangeListener ( this.listener );
    }
    super.dispose ();
}
 

import org.eclipse.core.databinding.observable.set.IObservableSet; //导入依赖的package包/类
/**
 * Set the new input set
 * <p>
 * The old input set will be returned but not disposed
 * </p>
 * 
 * @param input
 *            the new input set or <code>null</code> to set none
 * @return the old input set or <code>null</code> if none was present
 */
public IObservableSet setInput ( final IObservableSet input )
{
    final IObservableSet oldInput = this.input;

    if ( this.input != null )
    {
        detachInput ();
    }

    if ( this.viewer != null && input != null )
    {
        this.input = input;
        attachInput ();
    }

    return oldInput;
}
 

import org.eclipse.core.databinding.observable.set.IObservableSet; //导入依赖的package包/类
private void update ()
{
    this.unionSet.removeSetChangeListener ( this.setListener );
    this.unionSet.dispose ();
    this.descriptors.clear ();

    final List<IObservableSet> childSets = new LinkedList<IObservableSet> ();

    for ( final DetailComponent component : this.subs )
    {
        childSets.add ( component.getDescriptors () );
    }

    if ( childSets.isEmpty () )
    {
        this.unionSet = Observables.emptyObservableSet ();
    }
    else
    {
        this.unionSet = new UnionSet ( childSets.toArray ( new IObservableSet[childSets.size ()] ) );
    }

    this.unionSet.addSetChangeListener ( this.setListener );
    this.descriptors.addAll ( this.unionSet );
}
 

import org.eclipse.core.databinding.observable.set.IObservableSet; //导入依赖的package包/类
@Override
public IObservable createObservable ( final Object target )
{
    if ( target instanceof IObservableSet )
    {
        return (IObservable)target;
    }
    else if ( target instanceof TreeNode )
    {
        return ( (TreeNode)target ).createObservable ();
    }
    else
    {
        return null;
    }
}
 

import org.eclipse.core.databinding.observable.set.IObservableSet; //导入依赖的package包/类
@Override
public Object execute ( final ExecutionEvent event ) throws ExecutionException
{
    final Component component = SelectionHelper.first ( getSelection (), Component.class );
    if ( component == null )
    {
        return null;
    }

    try
    {
        final IObservableSet input = Helper.createObversableInput ( DisplayRealm.getRealm ( getShell ().getDisplay () ), component );
        new ComponentOutputDialog ( getShell (), input ).open ();
    }
    catch ( final Exception e )
    {
        StatusManager.getManager ().handle ( StatusHelper.convertStatus ( Activator.PLUGIN_ID, "Failed to generate component output", e ), StatusManager.BLOCK );
        throw new ExecutionException ( "Failed to generate component output", e );
    }

    return null;
}
 

import org.eclipse.core.databinding.observable.set.IObservableSet; //导入依赖的package包/类
private void bindAlgoParamValues() {
	DataBindingContext ctx = new DataBindingContext();
	IObservableSet modelSet = BeansObservables.observeSet(
			Realm.getDefault(), selectedAlgorithm, "algorithms");
	// ViewerSupport.bind(checkboxTableViewer, modelSet,
	// BeanProperties.value(Algorithm.class, "name"));

	IObservableSet widgetSet = ViewersObservables.observeCheckedElements(
			algorithmTableViewer, Algorithm.class);
	// modelSet = BeansObservables.obser(Realm.getDefault(),
	// selectedAlgorithm, "algorithms");

	ctx.bindSet(widgetSet, modelSet);

	// .observe(key);
	// ctx.bindSet(widgetSet, modelSet);
	// IObservableValue modelValue = BeanProperties.value(
	// AlgorithmParameter.class, btnBindding.get(key)).observe(
	// algoPara);

}
 

import org.eclipse.core.databinding.observable.set.IObservableSet; //导入依赖的package包/类
public ListeningStyledCellLabelProvider ( final IObservableSet itemsThatNeedLabels )
{
    this.items = itemsThatNeedLabels;
    this.items.addSetChangeListener ( this.listener );
    for ( final Iterator<?> it = this.items.iterator (); it.hasNext (); )
    {
        addListenerTo ( it.next () );
    }
}
 

import org.eclipse.core.databinding.observable.set.IObservableSet; //导入依赖的package包/类
protected void addSource ( final IObservableSet observableSet )
{
    if ( observableSet == null )
    {
        return;
    }

    this.sources.add ( observableSet );
    observableSet.addSetChangeListener ( this.listener );
    for ( final Iterator<?> it = observableSet.iterator (); it.hasNext (); )
    {
        addListenerTo ( it.next () );
    }
}
 

import org.eclipse.core.databinding.observable.set.IObservableSet; //导入依赖的package包/类
@Override
public IObservable createObservable ( final Object target )
{
    if ( target == Activator.ROOT )
    {
        return Observables.proxyObservableSet ( Activator.getDefault ().getTreeRoot () );
    }
    else if ( target instanceof TreeNode )
    {
        return new UnionSet ( new IObservableSet[] { ( (TreeNode)target ).getChildren (), ( (TreeNode)target ).getConnections () } );
    }
    return null;
}
 

import org.eclipse.core.databinding.observable.set.IObservableSet; //导入依赖的package包/类
/**
 * Create a new set with all known discoverers
 * <p>
 * The method creates a new instance which must be disposed by the caller.
 * </p>
 *
 * @return a new set of {@link ConnectionDiscovererBean}s
 */
public IObservableSet createDiscovererSet ()
{
    synchronized ( this )
    {
        if ( this.discoverers == null )
        {
            createDiscoverers ();
        }
        return Observables.proxyObservableSet ( this.discoverers );
    }
}
 

import org.eclipse.core.databinding.observable.set.IObservableSet; //导入依赖的package包/类
/**
 * Get the list of known stores (ConnectionStore)
 * <p>
 * This instance must not be disposed. If you need an instance that can be
 * disposed you need to wrap the received instance using
 * {@link Observables#proxyObservableSet(IObservableSet)}
 * </p>
 *
 * @return a list of {@link ConnectionDiscovererBean}s which implement the
 *         {@link ConnectionStore} interface
 */
public IObservableSet getStoresSet ()
{
    synchronized ( this )
    {
        if ( this.stores == null )
        {
            createDiscoverers ();
        }
        return this.stores;
    }
}
 

import org.eclipse.core.databinding.observable.set.IObservableSet; //导入依赖的package包/类
/**
 * Returns a list of descriptors used by this and all sub components
 *
 * @return the list of descriptors. It never returns <code>null</code>.
 */
@Override
public IObservableSet getDescriptors ()
{
    final List<IObservableSet> lists = new LinkedList<IObservableSet> ();

    lists.add ( this.descriptors );

    for ( final ComponentVisibility visibility : this.visibilites )
    {
        lists.add ( visibility.getDescriptors () );
    }

    return new UnionSet ( lists.toArray ( new IObservableSet[lists.size ()] ) );
}
 

import org.eclipse.core.databinding.observable.set.IObservableSet; //导入依赖的package包/类
public ServerLabelProvider ( final IObservableSet knownElements )
{
    super ( new IObservableMap[] { //
    BeanProperties.value ( "running" ).observeDetail ( knownElements ), //
    BeanProperties.value ( "error" ).observeDetail ( knownElements ) //
    } );
    this.errorImage = HivesPlugin.getDefault ().getImageRegistry ().get ( ImageConstants.IMG_ERROR );
    this.runningImage = HivesPlugin.getDefault ().getImageRegistry ().get ( ImageConstants.IMG_RUNNING );
    this.stoppedImage = HivesPlugin.getDefault ().getImageRegistry ().get ( ImageConstants.IMG_STOPPED );
}
 

import org.eclipse.core.databinding.observable.set.IObservableSet; //导入依赖的package包/类
@Override
public IObservable createObservable ( final Object target )
{
    logger.debug ( "Getting observable for: {}", target );
    if ( target instanceof IObservableSet )
    {
        return Observables.proxyObservableSet ( (IObservableSet)target );
    }
    else if ( target instanceof Master )
    {
        return Observables.proxyObservableSet ( ( (Master)target ).getEntries () );
    }
    else if ( target instanceof ItemEntry )
    {
        final ItemEntry itemEntry = (ItemEntry)target;
        if ( itemEntry.getCustomizationRequest () != null && itemEntry.getCustomizationRequest ().getComponent () != null )
        {
            final WritableSet result = new WritableSet ();
            result.add ( new ClassInformationProvider ( itemEntry.getCustomizationRequest ().getComponent ().getClass () ) );
            return result;
        }
    }
    else if ( target instanceof ClassInformationProvider )
    {
        return ( (ClassInformationProvider)target ).createSuper ( null );
    }
    return null;
}
 

import org.eclipse.core.databinding.observable.set.IObservableSet; //导入依赖的package包/类
public IObservableSet createSuper ( final Realm realm )
{
    final WritableSet result = new WritableSet ( realm != null ? realm : Realm.getDefault () );
    if ( this.classInformation != null )
    {
        add ( result, this.classInformation.getSuperclass () );
        for ( final Class<?> iface : this.classInformation.getInterfaces () )
        {
            add ( result, iface );
        }
    }
    return result;
}
 

import org.eclipse.core.databinding.observable.set.IObservableSet; //导入依赖的package包/类
/**
 * Modell m�dos�t�s�ra t�rt�n� feliratkoz�s �s annak hat�s�ra jogosults�g ellen�rz�s inid�t�sa
 */
public void initAccessControllChangeTrack() {
	try {
		@SuppressWarnings("deprecation")
		AdvancedIncQueryEngine engine = AdvancedIncQueryEngine
				.createUnmanagedEngine(resource);
		Set<IQuerySpecification<? extends IncQueryMatcher<? extends IPatternMatch>>> specifications = QuerySpecificationRegistry
				.getContributedQuerySpecifications();
		ArrayList<IObservableSet> observableSetList = new ArrayList<IObservableSet>();

		for (IQuerySpecification<? extends IncQueryMatcher<? extends IPatternMatch>> s : specifications) {
			IObservableSet set = IncQueryObservables.observeMatchesAsSet(s
					.getMatcher(engine));
			observableSetList.add(set);
		}

		IObservableSet[] observabelArray = observableSetList
				.toArray(new IObservableSet[observableSetList.size()]);
		UnionSet union = new UnionSet(observabelArray);
		union.addSetChangeListener(new ISetChangeListener() {

			@Override
			public void handleSetChange(SetChangeEvent event) {
				// �llpotv�ltoz�k ellen�rz�se
				if (verifier.getLastExecutionStep() == null
						|| verifier.getLastExecutionStep() != getChangeState()) {
					// Jogosults�g ki�rt�kel�s elind�t�sa
					verifier.printExecutedResult(getChangeState());
				} else {
					// Az �llapotv�ltoz�k megegyeznek, ekkor nem kell semmit
					// se csin�lni
				}
			}
		});
	} catch (IncQueryException e) {
		e.printStackTrace();
	}

}
 

import org.eclipse.core.databinding.observable.set.IObservableSet; //导入依赖的package包/类
private TableViewer createUniverseTable(Composite parent) {
	TableViewer tableViewer = new TableViewer(parent, SWT.NONE);
	Table table = tableViewer.getTable();
	table.setLayoutData(new GridData(SWT.FILL, SWT.FILL, true, true));
	table.setHeaderVisible(true);
	table.setLinesVisible(true);

	TableViewerColumn nameCol = new TableViewerColumn(tableViewer, SWT.NONE);
	nameCol.getColumn().setWidth(200);
	nameCol.getColumn().setText(Messages.projectUniverseNamePropertyLabel);

	TableViewerColumn locationCol = new TableViewerColumn(tableViewer, SWT.NONE);
	locationCol.getColumn().setWidth(400);
	locationCol.getColumn().setText(Messages.projectUniverseFilePropertyLabel);

	tableViewer.setSorter(new ViewerSorter());

	IObservableSet input = BeansObservables.observeSet(universeDefinitionsModel, UniverseDefinitionsModel.PN_UNIVERSE_FILES);
	IValueProperty[] labelProperties = BeanProperties.values(new String[] { UniverseFile.PN_NAME, UniverseFile.PN_LOCATION });
	ViewerSupport.bind(tableViewer, input, labelProperties);

	return tableViewer;
}
 

import org.eclipse.core.databinding.observable.set.IObservableSet; //导入依赖的package包/类
private void bindProjectPreviewTable() {
	IObservableSet observableVersioningProjects = BeansObservables.observeSet(editVersionModel, EditVersionModel.PN_PROJECTS);
	IBeanValueProperty[] labelProperties = BeanProperties.values(new String[] { VersioningProject.PN_PROJECT_ID, VersioningProject.PN_OLD_VERSION, VersioningProject.PN_NEW_VERSION });
	
	ObservableSetContentProvider contentProvider = new ObservableSetContentProvider();
	projectPreviewTable.setContentProvider(contentProvider);
	projectPreviewTable.setLabelProvider(new TableLabelProvider(projectPreviewTable.getTable().getDisplay(), Properties.observeEach(contentProvider.getKnownElements(), labelProperties)));
	projectPreviewTable.setInput(observableVersioningProjects);
	
	projectPreviewTable.setCheckStateProvider(new ObservableCheckStateProvider<CheckboxTableViewer>(projectPreviewTable, observableVersioningProjects,
			BeanProperties.value(VersioningProject.PN_SELECTED)));
}
 

import org.eclipse.core.databinding.observable.set.IObservableSet; //导入依赖的package包/类
public ObservableCheckStateProvider(T checkableViewer, IObservableSet checkableElements, IValueProperty checkedAttribute, IValueProperty grayedAttribute) {
	this.checkableViewer = checkableViewer;
	this.checkedAttribute = checkedAttribute;
	this.checkedMap = checkedAttribute.observeDetail(checkableElements);
	this.grayedAttribute = grayedAttribute;
	checkStateListener = new CheckStateListener(checkedMap);
	refreshViewerListener = new RefreshViewerListener(checkableViewer);
	addCheckStateListener();
	addRefreshViewerListener();
}