#ifndef HLDSTREAMSOURCE_H
#define HLDSTREAMSOURCE_H

#include "hldsource.h"
#include "TString.h"

class HldStreamSource : public HldSource {

   protected:
      Int_t    refId;     // Reference run id for initialization
      TString  currNodeName;
      TString  fileName;  // dummy filename composed from time
      Int_t    runId;     // store runId to compare in next event
      Bool_t   event_already_read; //!< mark that we already read event
      TIterator * iter;

   public:
      HldStreamSource(void);
      HldStreamSource(const Text_t *nodeName, Double_t maxage = -1);
      ~HldStreamSource(void);
      virtual Bool_t init();
      virtual Int_t getCurrentRunId(void);
      virtual Int_t getCurrentRefId(void) {return refId;}
      virtual EDsState getNextEvent(Bool_t doUnpack=kTRUE);
      virtual Text_t const *getCurrentFileName(void) {return fileName.Data();}

      void setRefId(Int_t r) { refId=r; }
      const char* getNodeName() { return currNodeName.Data(); }

      ClassDef(HldStreamSource,0) //Data source to read rpc buffers;
};

#endif /* !HLDSTREAMSOURCE_H */