ThreadedTripleStreamInserter.h

#include <knowRDF/TripleStreamListener.h>
#include <QSharedPointer>
 
namespace kDB
{
  namespace Repository
  {
    class TriplesStore;
    class ThreadedTripleStreamInserter : public knowRDF::TripleStreamListener
    {
    public:
      ThreadedTripleStreamInserter(const TriplesStore& _triplesStore, int _max_queue_size = std::numeric_limits< int >::max());
      virtual ~ThreadedTripleStreamInserter();
      virtual void triple(const knowRDF::Triple& _triple);
      void waitForFinished();
    private:
      struct Private;
      Private* const d;
    };
  }
}