//  Copyright (c) 2008 Ole Weidner (oweidner@cct.lsu.edu)
// 
//  Distributed under the Boost Software License, Version 1.0. (See accompanying 
//  file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)

#if !defined(ADAPTORS_LSF_JOB_ISTREAM_HPP)
#define ADAPTORS_LSF_JOB_ISTREAM_HPP

// saga includes
#include <saga/saga.hpp>
#include <saga/saga/adaptors/task.hpp>

// saga engine includes
#include <saga/impl/job.hpp>

// adaptor includes
#include "lsf_job_stream.hpp"


////////////////////////////////////////////////////////////////////////
namespace saga { namespace adaptors { namespace lsf
{
  class istream : public saga::job::istream
  {
    private:
      typedef saga::adaptors::lsf::stream <saga::adaptors::istream_ptr> 
              impl_type;

    public:
      template <typename Stream>
      istream (saga::impl::v1_0::job_cpi * cpi, 
               Stream                    & child_istream)
        : saga::job::istream (new impl_type (cpi, child_istream.rdbuf ()))
      {
      }
  };

}}} // namespace lsf_job
////////////////////////////////////////////////////////////////////////

#endif // !defined(ADAPTORS_LSF_JOB_ISTREAM_HPP)