streampipe.java

FMJ（freedom media for java)是java视频开发的新选择

package net.sf.fmj.media.multiplexer;

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;

import javax.media.Buffer;

import net.sf.fmj.media.BufferQueueInputStream;

/**
 * A way of converting an output stream to an input stream.
 * @author Ken Larson
 *
 */
public class StreamPipe
{
	private final BufferQueueInputStream is = new BufferQueueInputStream();
	private final MyOutputStream os = new MyOutputStream();
	
	public InputStream getInputStream()
	{	return is;
	}
	
	public OutputStream getOutputStream()
	{	return os;
	}
	
	private Buffer createBuffer(byte[] data, int offset, int length)
	{
		Buffer b = new Buffer();
		// TODO: set format to something? - doesn't seem needed.
		b.setData(data);
		b.setOffset(offset);
		b.setLength(length);
		return b;
	}
	
	private Buffer createEOMBuffer()
	{
		Buffer b = new Buffer();
		// TODO: set format to something? - doesn't seem needed.
		b.setData(new byte[0]);
		b.setOffset(0);
		b.setLength(0);
		b.setEOM(true);
		return b;
	}
	
	private class MyOutputStream extends OutputStream
	{

		public void write(int b) throws IOException
		{
			write(new byte[] {(byte) b});
		}

		public void write(byte[] b, int off, int len) throws IOException
		{
			is.blockingPut(createBuffer(b, off, len)); 
		}

		public void write(byte[] b) throws IOException
		{
			write(b, 0, b.length);
		}

		public void close() throws IOException
		{
			System.out.println("MyOutputStream Closing");
			is.blockingPut(createEOMBuffer());

			super.close();
		}
		
		
	}
}