KinesisManagerStatus KinesisStreamManager::InitializeStreamSubscription()

in kinesis_manager/src/kinesis_stream_manager.cpp [181:191]

• 11 lines of code
• 3 McCabe index (conditional complexity)

KinesisManagerStatus KinesisStreamManager::InitializeStreamSubscription(
  const StreamSubscriptionDescriptor & descriptor)
{
  KinesisManagerStatus status = subscription_installer_->Install(descriptor);
  if (KINESIS_MANAGER_STATUS_SUCCEEDED(status) && !descriptor.rekognition_data_stream.empty()) {
    RekognitionStreamInfo rekognition_info{
      .data_stream_name = Aws::String(descriptor.rekognition_data_stream.c_str())};
    rekognition_config_.insert({descriptor.stream_name, rekognition_info});
  }
  return status;
}