tikhomirov@312: /*
tikhomirov@312:  * Copyright (c) 2011 TMate Software Ltd
tikhomirov@312:  *  
tikhomirov@312:  * This program is free software; you can redistribute it and/or modify
tikhomirov@312:  * it under the terms of the GNU General Public License as published by
tikhomirov@312:  * the Free Software Foundation; version 2 of the License.
tikhomirov@312:  *
tikhomirov@312:  * This program is distributed in the hope that it will be useful,
tikhomirov@312:  * but WITHOUT ANY WARRANTY; without even the implied warranty of
tikhomirov@312:  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
tikhomirov@312:  * GNU General Public License for more details.
tikhomirov@312:  *
tikhomirov@312:  * For information on how to redistribute this software under
tikhomirov@312:  * the terms of a license other than GNU General Public License
tikhomirov@312:  * contact TMate Software at support@hg4j.com
tikhomirov@312:  */
tikhomirov@312: package org.tmatesoft.hg.internal;
tikhomirov@312: 
tikhomirov@312: import org.tmatesoft.hg.internal.Lifecycle.Callback;
tikhomirov@312: import org.tmatesoft.hg.util.CancelSupport;
tikhomirov@312: import org.tmatesoft.hg.util.CancelledException;
tikhomirov@312: 
tikhomirov@312: /**
tikhomirov@312:  *
tikhomirov@312:  * @author Artem Tikhomirov
tikhomirov@312:  * @author TMate Software Ltd.
tikhomirov@312:  */
tikhomirov@312: public class IterateControlMediator {
tikhomirov@312: 
tikhomirov@312: 	private final CancelSupport src;
tikhomirov@312: 	private Callback receiver;
tikhomirov@312: 
tikhomirov@312: 	public IterateControlMediator(CancelSupport source, Lifecycle.Callback target) {
tikhomirov@312: 		assert target != null;
tikhomirov@312: 		src = source;
tikhomirov@312: 		receiver = target;
tikhomirov@312: 	}
tikhomirov@312: 
tikhomirov@312: 	public boolean checkCancelled() {
tikhomirov@312: 		if (src == null) {
tikhomirov@312: 			return false;
tikhomirov@312: 		}
tikhomirov@312: 		try {
tikhomirov@312: 			src.checkCancelled();
tikhomirov@312: 			return false;
tikhomirov@312: 		} catch (CancelledException ex) {
tikhomirov@312: 			receiver.stop();
tikhomirov@312: 			return true;
tikhomirov@312: 		}
tikhomirov@312: 	}
tikhomirov@312: 	
tikhomirov@312: 	public void stop() {
tikhomirov@312: 		receiver.stop();
tikhomirov@312: 	}
tikhomirov@312: }