arts
kioinputstream_impl.h
00001
00002
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013
00014
00015
00016
00017
00018
00019
00020
00021
00022 #ifndef KIOINPUTSTREAM_IMPL
00023 #define KIOINPUTSTREAM_IMPL
00024
00025 #include <tqobject.h>
00026 #include <tqcstring.h>
00027 #include <tdeio/jobclasses.h>
00028 #include <kurl.h>
00029 #include "artskde.h"
00030 #include "stdsynthmodule.h"
00031
00032 namespace Arts {
00033
00034 class TDEIOInputStream_impl : public TQObject, virtual public TDEIOInputStream_skel,
00035 virtual public InputStream_skel,
00036 virtual public StdSynthModule
00037 {
00038 Q_OBJECT
00039 public:
00040 TDEIOInputStream_impl();
00041 ~TDEIOInputStream_impl();
00042
00043 void streamStart();
00044 void streamEnd();
00045
00046 bool eof();
00047 bool seekOk();
00048 long size();
00049 long seek(long);
00050
00051 bool openURL(const std::string& url);
00052
00053 void processQueue();
00054 void request_outdata(DataPacket<mcopbyte> *packet);
00055
00056 long bufferPackets() { return m_packetBuffer; }
00057 void bufferPackets(long i) { m_packetBuffer = i; }
00058
00059 long packetSize() { return m_packetSize; }
00060
00061 signals:
00062 void mimeTypeFound(const TQString & mimetype);
00063
00064 private slots:
00065 void slotData(TDEIO::Job *, const TQByteArray &);
00066 void slotResult(TDEIO::Job *);
00067 void slotScanMimeType(TDEIO::Job *, const TQString &mimetype);
00068 void slotTotalSize(TDEIO::Job *, TDEIO::filesize_t size);
00069
00070 private:
00071 KURL m_url;
00072 TDEIO::TransferJob *m_job;
00073 TQByteArray m_data;
00074 bool m_finished;
00075 bool m_firstBuffer;
00076 bool m_streamStarted;
00077 bool m_streamSuspended;
00078 bool m_streamPulled;
00079
00080 unsigned int m_packetBuffer;
00081 const unsigned int m_packetSize;
00082 TDEIO::filesize_t m_size;
00083
00084 static const unsigned int PACKET_COUNT;
00085 };
00086
00087 }
00088
00089 #endif