# Copyright (C) 2015-2017 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 # Defines behaviour around combiners # # @api private # # @since 2.1.0 module Combineable # @return [ Array ] requests The provided requests. attr_reader :requests # @return [ true, false ] has_collation Whether one or more operations has a collation defined. attr_reader :has_collation # Create the ordered combiner. # # @api private # # @example Create the ordered combiner. # OrderedCombiner.new([{ insert_one: { _id: 0 }}]) # # @param [ Array ] requests The bulk requests. # # @since 2.1.0 def initialize(requests) @requests = requests @has_collation = false end private def combine_requests(ops) requests.reduce(ops) do |operations, request| add(operations, request.keys.first, request.values.first) end end end end end