Skip to content

Commit 92ddf64

Browse files
committed
Move valid_doc method to BulkWritable module and account for Chunk serialization
1 parent 68d1726 commit 92ddf64

File tree

3 files changed

+5
-8
lines changed

3 files changed

+5
-8
lines changed

lib/mongo/bulk_write/bulk_writable.rb

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -85,6 +85,11 @@ def execute
8585

8686
private
8787

88+
def valid_doc?(doc)
89+
doc.respond_to?(:keys) ||
90+
doc.respond_to?(:document)
91+
end
92+
8893
def write_concern
8994
@write_concern ||= WriteConcern.get(@options[:write_concern]) ||
9095
@collection.write_concern

lib/mongo/bulk_write/deletable.rb

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -22,10 +22,6 @@ module Deletable
2222

2323
private
2424

25-
def valid_doc?(doc)
26-
doc.respond_to?(:keys)
27-
end
28-
2925
def validate_delete_op!(type, d)
3026
raise Error::InvalidBulkOperation.new(type, d) unless valid_doc?(d)
3127
end

lib/mongo/bulk_write/insertable.rb

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -22,10 +22,6 @@ module Insertable
2222

2323
private
2424

25-
def valid_doc?(doc)
26-
doc.respond_to?(:keys)
27-
end
28-
2925
def validate_insert_ops!(type, inserts)
3026
if inserts.empty?
3127
raise Error::InvalidBulkOperation.new(type, inserts)

0 commit comments

Comments
 (0)