AudioStream.h

 
#pragma once
#include <aws/core/utils/event/EventStream.h>
#include <aws/core/utils/stream/HttpWriteDataStreamBuf.h>
#include <aws/transcribestreaming/TranscribeStreamingService_EXPORTS.h>
#include <aws/transcribestreaming/model/AudioEvent.h>
#include <aws/transcribestreaming/model/ConfigurationEvent.h>
 
#include <utility>
 
namespace Aws {
namespace TranscribeStreamingService {
namespace Model {
 
class AWS_TRANSCRIBESTREAMINGSERVICE_API AudioStream : public Aws::Utils::Event::EventEncoderStream {
 public:
  AudioStream() = default;
  explicit AudioStream(std::shared_ptr<Aws::Utils::Stream::HttpWriteDataStreamBuf> streambuf)
      : Aws::Utils::Event::EventEncoderStream(std::move(streambuf)) {}
  AudioStream& WriteAudioEvent(const AudioEvent& value) {
    Aws::Utils::Event::Message msg;
    if (!value.GetAudioChunk().empty()) {
      msg.InsertEventHeader(":message-type", Aws::String("event"));
      msg.InsertEventHeader(":event-type", Aws::String("AudioEvent"));
      msg.InsertEventHeader(":content-type", Aws::String("application/octet-stream"));
      msg.WriteEventPayload(value.GetAudioChunk());
    }
    WriteEvent(msg);
    return *this;
  }
  AudioStream& WriteConfigurationEvent(const ConfigurationEvent& value) {
    Aws::Utils::Event::Message msg;
    msg.InsertEventHeader(":message-type", Aws::String("event"));
    msg.InsertEventHeader(":event-type", Aws::String("ConfigurationEvent"));
    msg.InsertEventHeader(":content-type", Aws::String("application/json"));
    msg.WriteEventPayload(value.Jsonize().View().WriteCompact());
    WriteEvent(msg);
    return *this;
  }
};
 
}  // namespace Model
}  // namespace TranscribeStreamingService
}  // namespace Aws