File tree Expand file tree Collapse file tree 10 files changed +9
-21
lines changed Expand file tree Collapse file tree 10 files changed +9
-21
lines changed Original file line number Diff line number Diff line change @@ -44,7 +44,7 @@ def execute(server)
4444
4545 private
4646
47- def base_command ( server )
47+ def selector ( server )
4848 { delete : coll_name ,
4949 deletes : send ( IDENTIFIER ) ,
5050 ordered : ordered? }
Original file line number Diff line number Diff line change @@ -44,7 +44,7 @@ def execute(server)
4444
4545 private
4646
47- def base_command ( server )
47+ def selector ( server )
4848 { delete : coll_name ,
4949 Protocol ::Msg ::DATABASE_IDENTIFIER => db_name ,
5050 ordered : ordered? }
Original file line number Diff line number Diff line change @@ -29,7 +29,7 @@ class Command
2929
3030 private
3131
32- def base_command ( server = nil )
32+ def selector ( server = nil )
3333 { :dropIndexes => coll_name , :index => index_name }
3434 end
3535
Original file line number Diff line number Diff line change @@ -46,7 +46,7 @@ def execute(server)
4646
4747 private
4848
49- def base_command ( server )
49+ def selector ( server )
5050 { insert : coll_name ,
5151 documents : send ( IDENTIFIER ) ,
5252 ordered : ordered? }
Original file line number Diff line number Diff line change @@ -45,7 +45,7 @@ def execute(server)
4545
4646 private
4747
48- def base_command ( server )
48+ def selector ( server )
4949 { insert : coll_name ,
5050 Protocol ::Msg ::DATABASE_IDENTIFIER => db_name ,
5151 ordered : ordered? }
Original file line number Diff line number Diff line change @@ -45,7 +45,7 @@ def execute(server)
4545
4646 private
4747
48- def base_command ( server )
48+ def selector ( server )
4949 sel = { :parallelCollectionScan => coll_name , :numCursors => cursor_count }
5050 sel [ :maxTimeMS ] = max_time_ms if max_time_ms
5151 sel [ :readConcern ] = read_concern if read_concern
Original file line number Diff line number Diff line change @@ -55,7 +55,7 @@ def apply_session_id!(selector)
5555 end
5656
5757 def command ( server )
58- sel = base_command ( server )
58+ sel = selector ( server )
5959 sel [ :writeConcern ] = write_concern . options if write_concern
6060 sel [ Protocol ::Msg ::DATABASE_IDENTIFIER ] = db_name
6161 sel [ READ_PREFERENCE ] = read . to_doc if read
Original file line number Diff line number Diff line change @@ -536,18 +536,6 @@ def txn_num
536536 #
537537 # @since 2.5.2
538538 def command ( server = nil )
539- base_command ( server )
540- end
541-
542- # The base command.
543- #
544- # @example Get the base command.
545- # specifiable.base_command
546- #
547- # @return [ Hash ] The base command.
548- #
549- # @since 2.5.2
550- def base_command ( server )
551539 selector ( server )
552540 end
553541
Original file line number Diff line number Diff line change @@ -45,7 +45,7 @@ def execute(server)
4545
4646 private
4747
48- def base_command ( server )
48+ def selector ( server )
4949 { update : coll_name ,
5050 updates : send ( IDENTIFIER ) ,
5151 ordered : ordered? }
Original file line number Diff line number Diff line change @@ -44,7 +44,7 @@ def execute(server)
4444
4545 private
4646
47- def base_command ( server )
47+ def selector ( server )
4848 { update : coll_name ,
4949 Protocol ::Msg ::DATABASE_IDENTIFIER => db_name ,
5050 ordered : ordered? }
You can’t perform that action at this time.
0 commit comments