1 files changed, 46 insertions, 0 deletions
diff --git a/common/plugins/org.eclipse.jpt.common.utility/src/org/eclipse/jpt/common/utility/internal/transformer/ConditionalInterruptibleTransformer.java b/common/plugins/org.eclipse.jpt.common.utility/src/org/eclipse/jpt/common/utility/internal/transformer/ConditionalInterruptibleTransformer.java
new file mode 100644
index 0000000000..ef042b91fb
--- /dev/null
+++ b/common/plugins/org.eclipse.jpt.common.utility/src/org/eclipse/jpt/common/utility/internal/transformer/ConditionalInterruptibleTransformer.java
@@ -0,0 +1,46 @@
+/*******************************************************************************
+ * Copyright (c) 2013 Oracle. 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:
+ *     Oracle - initial API and implementation
+ ******************************************************************************/
+package org.eclipse.jpt.common.utility.internal.transformer;
+
+import org.eclipse.jpt.common.utility.transformer.InterruptibleTransformer;
+import org.eclipse.jpt.common.utility.internal.ObjectTools;
+import org.eclipse.jpt.common.utility.predicate.Predicate;
+
+/**
+ * @see ConditionalTransformer
+ */
+public class ConditionalInterruptibleTransformer<I, O>
+	implements InterruptibleTransformer<I, O>
+{
+	private final Predicate<? super I> predicate;
+	private final InterruptibleTransformer<? super I, ? extends O> trueTransformer;
+	private final InterruptibleTransformer<? super I, ? extends O> falseTransformer;
+
+	public ConditionalInterruptibleTransformer(Predicate<? super I> predicate, InterruptibleTransformer<? super I, ? extends O> trueTransformer, InterruptibleTransformer<? super I, ? extends O> falseTransformer) {
+		super();
+		if ((predicate == null) || (trueTransformer == null) || (falseTransformer == null)) {
+			throw new NullPointerException();
+		}
+		this.predicate = predicate;
+		this.trueTransformer = trueTransformer;
+		this.falseTransformer = falseTransformer;
+	}
+
+	public O transform(I input) throws InterruptedException {
+		return this.predicate.evaluate(input) ?
+				this.trueTransformer.transform(input) :
+				this.falseTransformer.transform(input);
+	}
+
+	@Override
+	public String toString() {
+		return ObjectTools.toString(this, this.predicate);
+	}
+}