Sha256: 7685410b0c43010da5c15faac4d03cda8a9b4140c4df48e0e954af3ce3b52024
Contents?: true
Size: 1.43 KB
Versions: 11
Compression:
Stored size: 1.43 KB
Contents
# Copyright (C) 2015-2016 MongoDB, Inc. # # Licensed under the Apache License, Version 2.0 (the "License"); # you may not use this file except in compliance with the License. # You may obtain a copy of the License at # # http://www.apache.org/licenses/LICENSE-2.0 # # Unless required by applicable law or agreed to in writing, software # distributed under the License is distributed on an "AS IS" BASIS, # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. # See the License for the specific language governing permissions and # limitations under the License. module Mongo class BulkWrite # Combines groups of bulk write operations in order. # # @api private # # @since 2.1.0 class OrderedCombiner include Transformable include Validatable include Combineable # Combine the requests in order. # # @api private # # @example Combine the requests. # combiner.combine # # @return [ Array<Hash> ] The combined requests. # # @since 2.1.0 def combine combine_requests([]) end private def add(operations, name, document) operations.push({ name => []}) if next_group?(name, operations) operations[-1][name].push(transform(name, document)) operations end def next_group?(name, operations) !operations[-1] || !operations[-1].key?(name) end end end end
Version data entries
11 entries across 9 versions & 2 rubygems