class Google::Cloud::Bigquery::Table::AsyncInserter

def wait! timeout = nil
  synchronize do
    @thread_pool.shutdown
    @thread_pool.wait_for_termination timeout
  end
  self
end