wip

Author: comandeo-mongo

lib/mongo/operation/insert/op_msg.rb

@@ -38,7 +38,6 @@ def get_result(connection, context, options = {})
           connection.tracer.trace_command(message, context, connection) do
             result = Result.new(*dispatch_message(message, connection, context), @ids, context: context)
             yield result
-            validate_result(result, connection, context)
           end
         end
 

lib/mongo/operation/shared/executable.rb

@@ -92,7 +92,9 @@ def execute(connection, context:, options: {})
           end
         end
 
-        do_execute(connection, context, options)
+        do_execute(connection, context, options).tap do |result|
+          validate_result(result, connection, context)
+        end
       end
 
       private
@@ -106,7 +108,6 @@ def get_result(connection, context, options = {})
         connection.tracer.trace_command(message, context, connection) do
           result = result_class.new(*dispatch_message(message, connection, context, options), context: context, connection: connection)
           yield result
-          validate_result(result, connection, context)
         end
       end