public IEventWriter ReadEventWriter()

in processing-pipelines/common/csharp/ConfigReader.cs [44:56]

• 10 lines of code
• 2 McCabe index (conditional complexity)

        public IEventWriter ReadEventWriter()
        {
            // Use TOPIC_ID as an indicator for Pub/Sub event writer
            // Can be a single topic or a list of topics seperated by colon.
            var topicId = Read("TOPIC_ID", false);
            if (topicId != null)
            {
                var projectId = Read("PROJECT_ID");
                return new PubSubEventWriter(projectId, topicId, _logger);
            }

            return new CloudEventWriter(_cloudEventSource, _cloudEventType, _logger);
        }