javauis/mmapi_qt/baseline/javasrc.emc/com/nokia/microedition/media/BufferDataSource.java
/*
* Copyright (c) 2002 Nokia Corporation and/or its subsidiary(-ies).
* All rights reserved.
* This component and the accompanying materials are made available
* under the terms of "Eclipse Public License v1.0"
* which accompanies this distribution, and is available
* at the URL "http://www.eclipse.org/legal/epl-v10.html".
*
* Initial Contributors:
* Nokia Corporation - initial contribution.
*
* Contributors:
*
* Description: Buffered DataSource
*
*/
package com.nokia.microedition.media;
import javax.microedition.media.Control;
import javax.microedition.media.protocol.DataSource;
import javax.microedition.media.protocol.SourceStream;
import java.io.IOException;
import javax.microedition.io.Connection;
import com.nokia.mj.impl.utils.Logger;
/**
* BufferDataSource is used to read header from DataSource's SourceStream.
* This class delegates all method calls to DataSource given in constructor
* except getStream method which returns buffered SourceStream.
*/
public class BufferDataSource extends DataSource
{
// delegated source
protected DataSource iDataSource;
// buffers DataSource's first stream.
protected BufferSourceStream iSourceStream;
/**
* Constructor.
* @param aDataSource delegated DataSource
*/
public BufferDataSource(DataSource aDataSource) throws IOException
{
super(aDataSource.getLocator());
iDataSource = aDataSource;
SourceStream ss = aDataSource.getStreams()[ 0 ];
iSourceStream = new BufferSourceStream(ss);
}
/**
* Return header data.
* @return header data
*/
public byte[] getHeader() throws IOException
{
return iSourceStream.getHeader();
}
public int readAndBuffer(byte[] aBuffer, int aOffset, int aLength) throws IOException
{
return iSourceStream.readAndBuffer(aBuffer, aOffset, aLength);
}
/**
* from DataSource
* @return Content Type
* @see DataSource
*/
public String getContentType()
{
return iDataSource.getContentType();
}
/**
* from DataSource
* Connect to the stream
* @throws IOException
* @see DataSource
*/
public void connect() throws IOException
{
iDataSource.connect();
}
/**
* from DataSource
* Disconnect from the stream
*/
public void disconnect()
{
iDataSource.disconnect();
}
/**
* from DataSource
* Put DataSource to STARTED state
* @throws IOException Throw if DataSource is in wrong state
* @see DataSource
*/
public void start() throws IOException
{
iDataSource.start();
}
/**
* from DataSource
* Stops DataSource
* @see DataSource
*/
public void stop() throws IOException
{
iDataSource.stop();
}
/**
* from DataSource
* return sourceStreams of the DataSource
*
* @return set of source streams
* @see DataSource
*/
public SourceStream[] getStreams()
{
// return all streams from delegated DataSource except first
// buffered stream.
SourceStream[] originalStreams = iDataSource.getStreams();
SourceStream[] streams = new SourceStream[ originalStreams.length ];
System.arraycopy(originalStreams, 0,
streams, 0, originalStreams.length);
streams[ 0 ] = iSourceStream;
return streams;
}
/**
* from interface Controllable
* Method return controls of the DataSource
* @return Control
* @see Controllable
* @see DataSource
*/
public Control[] getControls()
{
return iDataSource.getControls();
}
/**
* from interface Controllable
* Return a control by the Control Type, not supported
* @param controlType type of the control
* @return Control
*/
public Control getControl(String aControlType)
{
return iDataSource.getControl(aControlType);
}
public DataSource getDataSource()
{
return iDataSource;
}
public Connection getConnection()
{
Logger.LOG(Logger.EJavaMMAPI, Logger.EInfo,"BufferDataSource getConnection +");
return iDataSource.getConnection();
}
}
// End of File