Contents

# frozen_string_literal: true

module ProconBypassMan
  module ExternalInput
    class ParseError < StandardError; end

    @@channels = nil

    # @return [Array<ProconBypassMan::ExternalInput::Channels::Base>]
    def self.channels
      @@channels
    end

    # @return [void]
    def self.prepare_channels
      @@channels = ProconBypassMan.config.external_input_channels
    end

    # @return [NilClass, String]
    # NOTE: 外部入力からのreadがボトルネックになるなら、Concurrent::Futureを使ってプロコンからの読み出しと並列化することを検討する
    def self.read
      raise '外部入力が未初期化です' if @@channels.nil?

      value = nil
      @@channels.each do |channel|
        value = channel.read
        break if value
      end
      value
    end
  end
end

require "procon_bypass_man/external_input/external_data"
require "procon_bypass_man/external_input/channels.rb"

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
procon_bypass_man-0.3.7	lib/procon_bypass_man/external_input.rb