send_message

in lib/kinesis_producer/daemon.rb [137:144]

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

    def send_message
      message = @outgoing_messages.pop
      size = [message.size].pack('N*')
      @out_channel.write(size)
      @out_channel.write(message)
      @out_channel.flush
    end