tools/remotetools/org.eclipse.ptp.remotetools.environment.launcher/src/org/eclipse/ptp/remotetools/environment/launcher/internal/process/MonitorOutputStream.java

/******************************************************************************
 * Copyright (c) 2006 IBM Corporation.
 * 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:
 *     IBM Corporation - Initial Implementation
 *
 *****************************************************************************/
package org.eclipse.ptp.remotetools.environment.launcher.internal.process;

import java.io.IOException;
import java.io.OutputStream;
import java.util.HashSet;
import java.util.Iterator;
import java.util.Set;

import org.eclipse.debug.core.IStreamListener;
import org.eclipse.debug.core.model.IStreamMonitor;

class MonitorOutputStream extends OutputStream implements IStreamMonitor {
	private Set listeners= new HashSet(1);
	
	public void addListener(IStreamListener listener) {
		listeners.add(listener);
	}

	public String getContents() {
		return null;
	}

	public void removeListener(IStreamListener listener) {
		listeners.remove(listener);

	}

	public void write(int b) throws IOException {
		Iterator iterator = listeners.iterator();
		while (iterator.hasNext()) {
			IStreamListener listener = (IStreamListener) iterator.next();
			byte bytes [] = new byte[1];
			bytes[0] = (byte)b;
			String text = new String(bytes);
			listener.streamAppended(text, this);
		}
	}
	
	public void write(byte[] b) throws IOException {
		Iterator iterator = listeners.iterator();
		while (iterator.hasNext()) {
			IStreamListener listener = (IStreamListener) iterator.next();
			String text = new String(b);
			listener.streamAppended(text, this);
		}
	}

	public void write(byte[] b, int off, int len) throws IOException {
		Iterator iterator = listeners.iterator();
		while (iterator.hasNext()) {
			IStreamListener listener = (IStreamListener) iterator.next();
			String text = new String(b, off, len);
			listener.streamAppended(text, this);
		}
	}
}