detail_single_stream_handler.hpp

#pragma once
 
#include "../../global.hpp"
 
#include "../_decl/decl_single_stream_handler.hpp"
 
#include "../../driver/_decl/decl_stream.hpp"
 
namespace Cvb
{
 
  CVB_BEGIN_INLINE_NS
 
  namespace Async
  {
 
    inline void SingleStreamHandler::HandleAsyncStream(const Driver::StreamPtr &stream)
    {
      try
      {
        auto waitResult = stream->Wait();
        HandleAsyncWaitResult(waitResult.Image, waitResult.Status);
      }
      catch (const std::exception &error)
      {
        if (!IsActive())
          return;
        HandleError(error);
      }
    }
    inline void SingleStreamHandler::HandleAsyncStream(const Driver::StreamPtr &stream) {…}
 
    inline void SingleStreamHandler::HandleAsyncWaitResult(const Driver::StreamImagePtr &, WaitStatus) {}
 
    inline void SingleStreamHandler::Setup(const Driver::StreamPtr &stream)
    {
      stream->Start();
    }
    inline void SingleStreamHandler::Setup(const Driver::StreamPtr &stream) {…}
 
    inline void SingleStreamHandler::TearDown(const Driver::StreamPtr &stream) noexcept
    {
      stream->TryAbort();
    }
    inline void SingleStreamHandler::TearDown(const Driver::StreamPtr &stream) noexcept {…}
 
    inline SingleStreamHandler::SingleStreamHandler(const Driver::StreamPtr &stream)
        : MultiStreamHandler(stream)
    {
    }
    inline SingleStreamHandler::SingleStreamHandler(const Driver::StreamPtr &stream) {…}
 
    inline void SingleStreamHandler::HandleAsyncStream(const std::vector<Driver::StreamPtr> &streamVector)
    {
      for (auto &stream : streamVector)
        HandleAsyncStream(stream);
    }
 
    inline void SingleStreamHandler::HandleAsyncWaitResult(
        const std::vector<Driver::WaitResult<typename Internal::DeliverableTraits<Driver::Stream>::type>> &)
    {
      throw std::runtime_error("list of streams not supported in SingleStreamHandler");
    }
 
    inline void SingleStreamHandler::Setup(const std::vector<Driver::StreamPtr> streamVector)
    {
      for (auto &stream : streamVector)
        Setup(stream);
    }
 
    inline void SingleStreamHandler::TearDown(const std::vector<Driver::StreamPtr> streamVector) noexcept
    {
      for (auto &stream : streamVector)
        TearDown(stream);
    }
 
  }  // namespace Async
 
  CVB_END_INLINE_NS
 
}  // namespace Cvb