import javax.media.protocol.PushBufferDataSource; //导入依赖的package包/类
public MonitorCDS(DataSource ds) {
// Get the stream from the actual datasource
// and create a MonitorStream from it
// Export the MonitorControl interface of the MonitorStream
if (ds instanceof PushBufferDataSource) {
    delegate = (PushBufferDataSource) ds;
    delStreams = delegate.getStreams();
    monitorStream = new MonitorStream(delStreams[0], this);
    monitorStreams = new PushBufferStream[] {monitorStream};
    controls = new Control[] {monitorStream};
}
   }
 

import javax.media.protocol.PushBufferDataSource; //导入依赖的package包/类
/**
 * Sets the media source this <tt>MediaHandler</tt>
 * should use to obtain content.
 */
public void setSource(DataSource source) throws IncompatibleSourceException {

    // Different types of DataSources need to handled differently.
    if (source instanceof PushBufferDataSource) {

	pushStrms = ((PushBufferDataSource)source).getStreams();
	unfinishedStrms = new SourceStream[pushStrms.length];

	// Set the transfer handler to receive pushed data from
	// the push DataSource.
	for (int i = 0; i < pushStrms.length; i++) {
	    pushStrms[i].setTransferHandler(this);
	    unfinishedStrms[i] = pushStrms[i];
	}


    } else if (source instanceof PullBufferDataSource) {

	pullStrms = ((PullBufferDataSource)source).getStreams();
	unfinishedStrms = new SourceStream[pullStrms.length];

	// For pull data sources, we'll start a thread per
	// stream to pull data from the source.
	loops = new Loop[pullStrms.length];
	for (int i = 0; i < pullStrms.length; i++) {
	    loops[i] = new Loop(this, pullStrms[i]);
	    unfinishedStrms[i] = pullStrms[i];
	}

    } else {

	// This handler only handles push or pull buffer datasource.
	throw new IncompatibleSourceException();

    }

    this.source = source;
    readBuffer = new Buffer();
}
 

import javax.media.protocol.PushBufferDataSource; //导入依赖的package包/类
/**
 * Sets the media source this <code>MediaHandler</code>
 * should use to obtain content.
 */
public void setSource(DataSource source) throws IncompatibleSourceException {

	// Different types of DataSources need to handled differently.
	if (source instanceof PushBufferDataSource) {

		pushStrms = ((PushBufferDataSource) source).getStreams();
		unfinishedStrms = new SourceStream[pushStrms.length];

		// Set the transfer handler to receive pushed data from
		// the push DataSource.
		for (int i = 0; i < pushStrms.length; i++) {
			pushStrms[i].setTransferHandler(this);
			unfinishedStrms[i] = pushStrms[i];
		}

	} else if (source instanceof PullBufferDataSource) {

		pullStrms = ((PullBufferDataSource) source).getStreams();
		unfinishedStrms = new SourceStream[pullStrms.length];

		// For pull data sources, we'll start a thread per
		// stream to pull data from the source.
		loops = new Loop[pullStrms.length];
		for (int i = 0; i < pullStrms.length; i++) {
			loops[i] = new Loop(this, pullStrms[i]);
			unfinishedStrms[i] = pullStrms[i];
		}

	} else {

		// This handler only handles push or pull buffer datasource.
		throw new IncompatibleSourceException();

	}

	this.source = source;
	readBuffer = new Buffer();
}