initialize

in lib/kinesis_producer/library.rb [69:76]

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

    def initialize(options)
      @binary_path = options.delete(:binary_path) || self.class.default_binary_path
      @message_id = Concurrent::AtomicFixnum.new(1)
      @futures = Concurrent::Map.new
      @child = Daemon.new(@binary_path, Handler.new(@futures), options)
      @child.start
    end