class SplitIoClient::SSE::NotificationManagerKeeper

def process_event_control(type)
  case type
  when 'STREAMING_PAUSED'
    @telemetry_runtime_producer.record_streaming_event(Telemetry::Domain::Constants::STREAMING_STATUS, PAUSED)
    push_status(Constants::PUSH_SUBSYSTEM_DOWN)
  when 'STREAMING_RESUMED'
    @telemetry_runtime_producer.record_streaming_event(Telemetry::Domain::Constants::STREAMING_STATUS, ENABLED)
    push_status(Constants::PUSH_SUBSYSTEM_READY) if @publisher_available.value
  when 'STREAMING_DISABLED'
    @telemetry_runtime_producer.record_streaming_event(Telemetry::Domain::Constants::STREAMING_STATUS, DISABLED)
    push_status(Constants::PUSH_SUBSYSTEM_OFF)
  else
    @config.logger.error("Incorrect event type: #{incoming_notification}")
  end
end