lib/logstash/outputs/bigquery/batcher.rb
# enqueue_push calls enqueue and if a batch is ready to go pushes it to
# the provided queue.
enqueue_push calls enqueue and if a batch is ready to go pushes it to
the provided queue.
enqueue_push calls enqueue and if a batch is ready to go pushes it to the provided queue .
def enqueue_push(message, queue)
          batch = enqueue message
          queue << batch unless batch.nil?
        end
def enqueue_push ( message , queue ) batch = enqueue message queue << batch unless batch . nil? end
enqueue_push calls enqueue and if a batch is ready to go pushes it to
the provided queue.
enqueue_push calls enqueue and if a batch is ready to go pushes it to the provided queue .
message
<not_specific>
queue
<not_specific>