pipedoutputstream.java

kaffe是一个java虚拟机的源代码。里面包含了一些java例程和标准的java包。

package java.io;


/*
 * Java core library component.
 *
 * Copyright (c) 1997, 1998
 *      Transvirtual Technologies, Inc.  All rights reserved.
 *
 * See the file "license.terms" for information on usage and redistribution
 * of this file.
 */
public class PipedOutputStream
  extends OutputStream
{
	PipedInputStream sink = null;

public PipedOutputStream() {
}

public PipedOutputStream(PipedInputStream snk) throws IOException {
	connect(snk);
}

public void close() throws IOException {
	if (sink != null) {
		sink.receivedLast();
		sink = null;
	}
}

public void connect(PipedInputStream snk) throws IOException {
	if (sink != null) {
		throw new IOException("already connected");
	}
	sink = snk;
	if (snk.src == null) {
		sink.connect(this);
	}
}

public void write(byte b[], int off, int len) throws IOException {
	if (sink == null) {
		throw new IOException();
	}
	super.write(b, off, len);
}

public void write(int b) throws IOException {
	if (sink == null) {
		throw new IOException();
	}
	sink.receive(b);
}
}