4j                           #    (    ,         4    :  =    B    G    L  ! ! " # #$ T % & &' Y ( ) ) * + + , - - . / /0 g 1 2 23 l 4 5 56 q 7 8 8 9 : : ;< z = > >?  @ A A BC D EF  G H I J I J K L LM  N O OPQmongoOperationPublisherELcom/mongodb/reactivestreams/client/internal/MongoOperationPublisher; SignatureJLcom/mongodb/reactivestreams/client/internal/MongoOperationPublisher;H(Lcom/mongodb/reactivestreams/client/internal/MongoOperationPublisher;)VCodeLineNumberTableLocalVariableTablethisALcom/mongodb/reactivestreams/client/internal/MongoCollectionImpl;LocalVariableTypeTableFLcom/mongodb/reactivestreams/client/internal/MongoCollectionImpl;M(Lcom/mongodb/reactivestreams/client/internal/MongoOperationPublisher;)V getNamespace()Lcom/mongodb/MongoNamespace;getDocumentClass()Ljava/lang/Class;()Ljava/lang/Class;getCodecRegistry/()Lorg/bson/codecs/configuration/CodecRegistry;getReadPreference()Lcom/mongodb/ReadPreference;getWriteConcern()Lcom/mongodb/WriteConcern;getReadConcern()Lcom/mongodb/ReadConcern;getPublisherHelperG()Lcom/mongodb/reactivestreams/client/internal/MongoOperationPublisher;L()Lcom/mongodb/reactivestreams/client/internal/MongoOperationPublisher;withDocumentClassG(Ljava/lang/Class;)Lcom/mongodb/reactivestreams/client/MongoCollection;newDocumentClassLjava/lang/Class;Ljava/lang/Class;g(Ljava/lang/Class;)Lcom/mongodb/reactivestreams/client/MongoCollection;withCodecRegistryc(Lorg/bson/codecs/configuration/CodecRegistry;)Lcom/mongodb/reactivestreams/client/MongoCollection; codecRegistry-Lorg/bson/codecs/configuration/CodecRegistry;h(Lorg/bson/codecs/configuration/CodecRegistry;)Lcom/mongodb/reactivestreams/client/MongoCollection;withReadPreferenceR(Lcom/mongodb/ReadPreference;)Lcom/mongodb/reactivestreams/client/MongoCollection;readPreferenceLcom/mongodb/ReadPreference;W(Lcom/mongodb/ReadPreference;)Lcom/mongodb/reactivestreams/client/MongoCollection;withWriteConcernP(Lcom/mongodb/WriteConcern;)Lcom/mongodb/reactivestreams/client/MongoCollection; writeConcernLcom/mongodb/WriteConcern;U(Lcom/mongodb/WriteConcern;)Lcom/mongodb/reactivestreams/client/MongoCollection;withReadConcernO(Lcom/mongodb/ReadConcern;)Lcom/mongodb/reactivestreams/client/MongoCollection; readConcernLcom/mongodb/ReadConcern;T(Lcom/mongodb/ReadConcern;)Lcom/mongodb/reactivestreams/client/MongoCollection;estimatedDocumentCount!()Lorg/reactivestreams/Publisher;3()Lorg/reactivestreams/Publisher;Y(Lcom/mongodb/client/model/EstimatedDocumentCountOptions;)Lorg/reactivestreams/Publisher;options8Lcom/mongodb/client/model/EstimatedDocumentCountOptions;k(Lcom/mongodb/client/model/EstimatedDocumentCountOptions;)Lorg/reactivestreams/Publisher;countDocuments<(Lorg/bson/conversions/Bson;)Lorg/reactivestreams/Publisher;filterLorg/bson/conversions/Bson;N(Lorg/bson/conversions/Bson;)Lorg/reactivestreams/Publisher;c(Lorg/bson/conversions/Bson;Lcom/mongodb/client/model/CountOptions;)Lorg/reactivestreams/Publisher;'Lcom/mongodb/client/model/CountOptions;u(Lorg/bson/conversions/Bson;Lcom/mongodb/client/model/CountOptions;)Lorg/reactivestreams/Publisher;S(Lcom/mongodb/reactivestreams/client/ClientSession;)Lorg/reactivestreams/Publisher; clientSession2Lcom/mongodb/reactivestreams/client/ClientSession;e(Lcom/mongodb/reactivestreams/client/ClientSession;)Lorg/reactivestreams/Publisher;n(Lcom/mongodb/reactivestreams/client/ClientSession;Lorg/bson/conversions/Bson;)Lorg/reactivestreams/Publisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Lorg/bson/conversions/Bson;)Lorg/reactivestreams/Publisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Lorg/bson/conversions/Bson;Lcom/mongodb/client/model/CountOptions;)Lorg/reactivestreams/Publisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Lorg/bson/conversions/Bson;Lcom/mongodb/client/model/CountOptions;)Lorg/reactivestreams/Publisher;distinct[(Ljava/lang/String;Ljava/lang/Class;)Lcom/mongodb/reactivestreams/client/DistinctPublisher; fieldNameLjava/lang/String; resultClassLjava/lang/Class;(Ljava/lang/String;Ljava/lang/Class;)Lcom/mongodb/reactivestreams/client/DistinctPublisher;v(Ljava/lang/String;Lorg/bson/conversions/Bson;Ljava/lang/Class;)Lcom/mongodb/reactivestreams/client/DistinctPublisher;(Ljava/lang/String;Lorg/bson/conversions/Bson;Ljava/lang/Class;)Lcom/mongodb/reactivestreams/client/DistinctPublisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Ljava/lang/String;Ljava/lang/Class;)Lcom/mongodb/reactivestreams/client/DistinctPublisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Ljava/lang/String;Ljava/lang/Class;)Lcom/mongodb/reactivestreams/client/DistinctPublisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Ljava/lang/String;Lorg/bson/conversions/Bson;Ljava/lang/Class;)Lcom/mongodb/reactivestreams/client/DistinctPublisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Ljava/lang/String;Lorg/bson/conversions/Bson;Ljava/lang/Class;)Lcom/mongodb/reactivestreams/client/DistinctPublisher;find4()Lcom/mongodb/reactivestreams/client/FindPublisher;9()Lcom/mongodb/reactivestreams/client/FindPublisher;E(Ljava/lang/Class;)Lcom/mongodb/reactivestreams/client/FindPublisher;w(Ljava/lang/Class;)Lcom/mongodb/reactivestreams/client/FindPublisher;O(Lorg/bson/conversions/Bson;)Lcom/mongodb/reactivestreams/client/FindPublisher;T(Lorg/bson/conversions/Bson;)Lcom/mongodb/reactivestreams/client/FindPublisher;`(Lorg/bson/conversions/Bson;Ljava/lang/Class;)Lcom/mongodb/reactivestreams/client/FindPublisher;(Lorg/bson/conversions/Bson;Ljava/lang/Class;)Lcom/mongodb/reactivestreams/client/FindPublisher;f(Lcom/mongodb/reactivestreams/client/ClientSession;)Lcom/mongodb/reactivestreams/client/FindPublisher;k(Lcom/mongodb/reactivestreams/client/ClientSession;)Lcom/mongodb/reactivestreams/client/FindPublisher;w(Lcom/mongodb/reactivestreams/client/ClientSession;Ljava/lang/Class;)Lcom/mongodb/reactivestreams/client/FindPublisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Ljava/lang/Class;)Lcom/mongodb/reactivestreams/client/FindPublisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Lorg/bson/conversions/Bson;)Lcom/mongodb/reactivestreams/client/FindPublisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Lorg/bson/conversions/Bson;)Lcom/mongodb/reactivestreams/client/FindPublisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Lorg/bson/conversions/Bson;Ljava/lang/Class;)Lcom/mongodb/reactivestreams/client/FindPublisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Lorg/bson/conversions/Bson;Ljava/lang/Class;)Lcom/mongodb/reactivestreams/client/FindPublisher; aggregateI(Ljava/util/List;)Lcom/mongodb/reactivestreams/client/AggregatePublisher;pipelineLjava/util/List;.Ljava/util/List<+Lorg/bson/conversions/Bson;>;l(Ljava/util/List<+Lorg/bson/conversions/Bson;>;)Lcom/mongodb/reactivestreams/client/AggregatePublisher;Z(Ljava/util/List;Ljava/lang/Class;)Lcom/mongodb/reactivestreams/client/AggregatePublisher;(Ljava/util/List<+Lorg/bson/conversions/Bson;>;Ljava/lang/Class;)Lcom/mongodb/reactivestreams/client/AggregatePublisher;{(Lcom/mongodb/reactivestreams/client/ClientSession;Ljava/util/List;)Lcom/mongodb/reactivestreams/client/AggregatePublisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Ljava/util/List<+Lorg/bson/conversions/Bson;>;)Lcom/mongodb/reactivestreams/client/AggregatePublisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Ljava/util/List;Ljava/lang/Class;)Lcom/mongodb/reactivestreams/client/AggregatePublisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Ljava/util/List<+Lorg/bson/conversions/Bson;>;Ljava/lang/Class;)Lcom/mongodb/reactivestreams/client/AggregatePublisher;watch<()Lcom/mongodb/reactivestreams/client/ChangeStreamPublisher;Q()Lcom/mongodb/reactivestreams/client/ChangeStreamPublisher;M(Ljava/lang/Class;)Lcom/mongodb/reactivestreams/client/ChangeStreamPublisher;(Ljava/lang/Class;)Lcom/mongodb/reactivestreams/client/ChangeStreamPublisher;L(Ljava/util/List;)Lcom/mongodb/reactivestreams/client/ChangeStreamPublisher;(Ljava/util/List<+Lorg/bson/conversions/Bson;>;)Lcom/mongodb/reactivestreams/client/ChangeStreamPublisher;](Ljava/util/List;Ljava/lang/Class;)Lcom/mongodb/reactivestreams/client/ChangeStreamPublisher;(Ljava/util/List<+Lorg/bson/conversions/Bson;>;Ljava/lang/Class;)Lcom/mongodb/reactivestreams/client/ChangeStreamPublisher;n(Lcom/mongodb/reactivestreams/client/ClientSession;)Lcom/mongodb/reactivestreams/client/ChangeStreamPublisher;(Lcom/mongodb/reactivestreams/client/ClientSession;)Lcom/mongodb/reactivestreams/client/ChangeStreamPublisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Ljava/lang/Class;)Lcom/mongodb/reactivestreams/client/ChangeStreamPublisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Ljava/lang/Class;)Lcom/mongodb/reactivestreams/client/ChangeStreamPublisher;~(Lcom/mongodb/reactivestreams/client/ClientSession;Ljava/util/List;)Lcom/mongodb/reactivestreams/client/ChangeStreamPublisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Ljava/util/List<+Lorg/bson/conversions/Bson;>;)Lcom/mongodb/reactivestreams/client/ChangeStreamPublisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Ljava/util/List;Ljava/lang/Class;)Lcom/mongodb/reactivestreams/client/ChangeStreamPublisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Ljava/util/List<+Lorg/bson/conversions/Bson;>;Ljava/lang/Class;)Lcom/mongodb/reactivestreams/client/ChangeStreamPublisher; mapReduce](Ljava/lang/String;Ljava/lang/String;)Lcom/mongodb/reactivestreams/client/MapReducePublisher; mapFunctionreduceFunctionb(Ljava/lang/String;Ljava/lang/String;)Lcom/mongodb/reactivestreams/client/MapReducePublisher;n(Ljava/lang/String;Ljava/lang/String;Ljava/lang/Class;)Lcom/mongodb/reactivestreams/client/MapReducePublisher;(Ljava/lang/String;Ljava/lang/String;Ljava/lang/Class;)Lcom/mongodb/reactivestreams/client/MapReducePublisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Ljava/lang/String;Ljava/lang/String;)Lcom/mongodb/reactivestreams/client/MapReducePublisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Ljava/lang/String;Ljava/lang/String;)Lcom/mongodb/reactivestreams/client/MapReducePublisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Ljava/lang/String;Ljava/lang/String;Ljava/lang/Class;)Lcom/mongodb/reactivestreams/client/MapReducePublisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Ljava/lang/String;Ljava/lang/String;Ljava/lang/Class;)Lcom/mongodb/reactivestreams/client/MapReducePublisher; bulkWrite1(Ljava/util/List;)Lorg/reactivestreams/Publisher;requests>Ljava/util/List<+Lcom/mongodb/client/model/WriteModel<+TT;>;>;(Ljava/util/List<+Lcom/mongodb/client/model/WriteModel<+TT;>;>;)Lorg/reactivestreams/Publisher;\(Ljava/util/List;Lcom/mongodb/client/model/BulkWriteOptions;)Lorg/reactivestreams/Publisher;+Lcom/mongodb/client/model/BulkWriteOptions;(Ljava/util/List<+Lcom/mongodb/client/model/WriteModel<+TT;>;>;Lcom/mongodb/client/model/BulkWriteOptions;)Lorg/reactivestreams/Publisher;c(Lcom/mongodb/reactivestreams/client/ClientSession;Ljava/util/List;)Lorg/reactivestreams/Publisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Ljava/util/List<+Lcom/mongodb/client/model/WriteModel<+TT;>;>;)Lorg/reactivestreams/Publisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Ljava/util/List;Lcom/mongodb/client/model/BulkWriteOptions;)Lorg/reactivestreams/Publisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Ljava/util/List<+Lcom/mongodb/client/model/WriteModel<+TT;>;>;Lcom/mongodb/client/model/BulkWriteOptions;)Lorg/reactivestreams/Publisher; insertOne3(Ljava/lang/Object;)Lorg/reactivestreams/Publisher;documentLjava/lang/Object;TT;Q(TT;)Lorg/reactivestreams/Publisher;^(Ljava/lang/Object;Lcom/mongodb/client/model/InsertOneOptions;)Lorg/reactivestreams/Publisher;+Lcom/mongodb/client/model/InsertOneOptions;|(TT;Lcom/mongodb/client/model/InsertOneOptions;)Lorg/reactivestreams/Publisher;e(Lcom/mongodb/reactivestreams/client/ClientSession;Ljava/lang/Object;)Lorg/reactivestreams/Publisher;(Lcom/mongodb/reactivestreams/client/ClientSession;TT;)Lorg/reactivestreams/Publisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Ljava/lang/Object;Lcom/mongodb/client/model/InsertOneOptions;)Lorg/reactivestreams/Publisher;(Lcom/mongodb/reactivestreams/client/ClientSession;TT;Lcom/mongodb/client/model/InsertOneOptions;)Lorg/reactivestreams/Publisher; insertMany documentsLjava/util/List<+TT;>;e(Ljava/util/List<+TT;>;)Lorg/reactivestreams/Publisher;](Ljava/util/List;Lcom/mongodb/client/model/InsertManyOptions;)Lorg/reactivestreams/Publisher;,Lcom/mongodb/client/model/InsertManyOptions;(Ljava/util/List<+TT;>;Lcom/mongodb/client/model/InsertManyOptions;)Lorg/reactivestreams/Publisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Ljava/util/List<+TT;>;)Lorg/reactivestreams/Publisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Ljava/util/List;Lcom/mongodb/client/model/InsertManyOptions;)Lorg/reactivestreams/Publisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Ljava/util/List<+TT;>;Lcom/mongodb/client/model/InsertManyOptions;)Lorg/reactivestreams/Publisher; deleteOnef(Lorg/bson/conversions/Bson;)Lorg/reactivestreams/Publisher;d(Lorg/bson/conversions/Bson;Lcom/mongodb/client/model/DeleteOptions;)Lorg/reactivestreams/Publisher;(Lcom/mongodb/client/model/DeleteOptions;(Lorg/bson/conversions/Bson;Lcom/mongodb/client/model/DeleteOptions;)Lorg/reactivestreams/Publisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Lorg/bson/conversions/Bson;)Lorg/reactivestreams/Publisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Lorg/bson/conversions/Bson;Lcom/mongodb/client/model/DeleteOptions;)Lorg/reactivestreams/Publisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Lorg/bson/conversions/Bson;Lcom/mongodb/client/model/DeleteOptions;)Lorg/reactivestreams/Publisher; deleteMany replaceOneN(Lorg/bson/conversions/Bson;Ljava/lang/Object;)Lorg/reactivestreams/Publisher; replacementi(Lorg/bson/conversions/Bson;TT;)Lorg/reactivestreams/Publisher;w(Lorg/bson/conversions/Bson;Ljava/lang/Object;Lcom/mongodb/client/model/ReplaceOptions;)Lorg/reactivestreams/Publisher;)Lcom/mongodb/client/model/ReplaceOptions;(Lorg/bson/conversions/Bson;TT;Lcom/mongodb/client/model/ReplaceOptions;)Lorg/reactivestreams/Publisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Lorg/bson/conversions/Bson;Ljava/lang/Object;)Lorg/reactivestreams/Publisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Lorg/bson/conversions/Bson;TT;)Lorg/reactivestreams/Publisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Lorg/bson/conversions/Bson;Ljava/lang/Object;Lcom/mongodb/client/model/ReplaceOptions;)Lorg/reactivestreams/Publisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Lorg/bson/conversions/Bson;TT;Lcom/mongodb/client/model/ReplaceOptions;)Lorg/reactivestreams/Publisher; updateOneW(Lorg/bson/conversions/Bson;Lorg/bson/conversions/Bson;)Lorg/reactivestreams/Publisher;update(Lorg/bson/conversions/Bson;Lorg/bson/conversions/Bson;)Lorg/reactivestreams/Publisher;(Lorg/bson/conversions/Bson;Lorg/bson/conversions/Bson;Lcom/mongodb/client/model/UpdateOptions;)Lorg/reactivestreams/Publisher;(Lcom/mongodb/client/model/UpdateOptions;(Lorg/bson/conversions/Bson;Lorg/bson/conversions/Bson;Lcom/mongodb/client/model/UpdateOptions;)Lorg/reactivestreams/Publisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Lorg/bson/conversions/Bson;Lorg/bson/conversions/Bson;)Lorg/reactivestreams/Publisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Lorg/bson/conversions/Bson;Lorg/bson/conversions/Bson;)Lorg/reactivestreams/Publisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Lorg/bson/conversions/Bson;Lorg/bson/conversions/Bson;Lcom/mongodb/client/model/UpdateOptions;)Lorg/reactivestreams/Publisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Lorg/bson/conversions/Bson;Lorg/bson/conversions/Bson;Lcom/mongodb/client/model/UpdateOptions;)Lorg/reactivestreams/Publisher;L(Lorg/bson/conversions/Bson;Ljava/util/List;)Lorg/reactivestreams/Publisher;(Lorg/bson/conversions/Bson;Ljava/util/List<+Lorg/bson/conversions/Bson;>;)Lorg/reactivestreams/Publisher;t(Lorg/bson/conversions/Bson;Ljava/util/List;Lcom/mongodb/client/model/UpdateOptions;)Lorg/reactivestreams/Publisher;(Lorg/bson/conversions/Bson;Ljava/util/List<+Lorg/bson/conversions/Bson;>;Lcom/mongodb/client/model/UpdateOptions;)Lorg/reactivestreams/Publisher;~(Lcom/mongodb/reactivestreams/client/ClientSession;Lorg/bson/conversions/Bson;Ljava/util/List;)Lorg/reactivestreams/Publisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Lorg/bson/conversions/Bson;Ljava/util/List<+Lorg/bson/conversions/Bson;>;)Lorg/reactivestreams/Publisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Lorg/bson/conversions/Bson;Ljava/util/List;Lcom/mongodb/client/model/UpdateOptions;)Lorg/reactivestreams/Publisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Lorg/bson/conversions/Bson;Ljava/util/List<+Lorg/bson/conversions/Bson;>;Lcom/mongodb/client/model/UpdateOptions;)Lorg/reactivestreams/Publisher; updateManyfindOneAndDeleteA(Lorg/bson/conversions/Bson;)Lorg/reactivestreams/Publisher;n(Lorg/bson/conversions/Bson;Lcom/mongodb/client/model/FindOneAndDeleteOptions;)Lorg/reactivestreams/Publisher;2Lcom/mongodb/client/model/FindOneAndDeleteOptions;s(Lorg/bson/conversions/Bson;Lcom/mongodb/client/model/FindOneAndDeleteOptions;)Lorg/reactivestreams/Publisher;s(Lcom/mongodb/reactivestreams/client/ClientSession;Lorg/bson/conversions/Bson;)Lorg/reactivestreams/Publisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Lorg/bson/conversions/Bson;Lcom/mongodb/client/model/FindOneAndDeleteOptions;)Lorg/reactivestreams/Publisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Lorg/bson/conversions/Bson;Lcom/mongodb/client/model/FindOneAndDeleteOptions;)Lorg/reactivestreams/Publisher;findOneAndReplaceD(Lorg/bson/conversions/Bson;TT;)Lorg/reactivestreams/Publisher;(Lorg/bson/conversions/Bson;Ljava/lang/Object;Lcom/mongodb/client/model/FindOneAndReplaceOptions;)Lorg/reactivestreams/Publisher;3Lcom/mongodb/client/model/FindOneAndReplaceOptions;w(Lorg/bson/conversions/Bson;TT;Lcom/mongodb/client/model/FindOneAndReplaceOptions;)Lorg/reactivestreams/Publisher;v(Lcom/mongodb/reactivestreams/client/ClientSession;Lorg/bson/conversions/Bson;TT;)Lorg/reactivestreams/Publisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Lorg/bson/conversions/Bson;Ljava/lang/Object;Lcom/mongodb/client/model/FindOneAndReplaceOptions;)Lorg/reactivestreams/Publisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Lorg/bson/conversions/Bson;TT;Lcom/mongodb/client/model/FindOneAndReplaceOptions;)Lorg/reactivestreams/Publisher;findOneAndUpdate\(Lorg/bson/conversions/Bson;Lorg/bson/conversions/Bson;)Lorg/reactivestreams/Publisher;(Lorg/bson/conversions/Bson;Lorg/bson/conversions/Bson;Lcom/mongodb/client/model/FindOneAndUpdateOptions;)Lorg/reactivestreams/Publisher;2Lcom/mongodb/client/model/FindOneAndUpdateOptions;(Lorg/bson/conversions/Bson;Lorg/bson/conversions/Bson;Lcom/mongodb/client/model/FindOneAndUpdateOptions;)Lorg/reactivestreams/Publisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Lorg/bson/conversions/Bson;Lorg/bson/conversions/Bson;)Lorg/reactivestreams/Publisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Lorg/bson/conversions/Bson;Lorg/bson/conversions/Bson;Lcom/mongodb/client/model/FindOneAndUpdateOptions;)Lorg/reactivestreams/Publisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Lorg/bson/conversions/Bson;Lorg/bson/conversions/Bson;Lcom/mongodb/client/model/FindOneAndUpdateOptions;)Lorg/reactivestreams/Publisher;o(Lorg/bson/conversions/Bson;Ljava/util/List<+Lorg/bson/conversions/Bson;>;)Lorg/reactivestreams/Publisher;~(Lorg/bson/conversions/Bson;Ljava/util/List;Lcom/mongodb/client/model/FindOneAndUpdateOptions;)Lorg/reactivestreams/Publisher;(Lorg/bson/conversions/Bson;Ljava/util/List<+Lorg/bson/conversions/Bson;>;Lcom/mongodb/client/model/FindOneAndUpdateOptions;)Lorg/reactivestreams/Publisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Lorg/bson/conversions/Bson;Ljava/util/List<+Lorg/bson/conversions/Bson;>;)Lorg/reactivestreams/Publisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Lorg/bson/conversions/Bson;Ljava/util/List;Lcom/mongodb/client/model/FindOneAndUpdateOptions;)Lorg/reactivestreams/Publisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Lorg/bson/conversions/Bson;Ljava/util/List<+Lorg/bson/conversions/Bson;>;Lcom/mongodb/client/model/FindOneAndUpdateOptions;)Lorg/reactivestreams/Publisher;drop3()Lorg/reactivestreams/Publisher;e(Lcom/mongodb/reactivestreams/client/ClientSession;)Lorg/reactivestreams/Publisher; createIndexkeyP(Lorg/bson/conversions/Bson;)Lorg/reactivestreams/Publisher;c(Lorg/bson/conversions/Bson;Lcom/mongodb/client/model/IndexOptions;)Lorg/reactivestreams/Publisher;'Lcom/mongodb/client/model/IndexOptions;w(Lorg/bson/conversions/Bson;Lcom/mongodb/client/model/IndexOptions;)Lorg/reactivestreams/Publisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Lorg/bson/conversions/Bson;)Lorg/reactivestreams/Publisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Lorg/bson/conversions/Bson;Lcom/mongodb/client/model/IndexOptions;)Lorg/reactivestreams/Publisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Lorg/bson/conversions/Bson;Lcom/mongodb/client/model/IndexOptions;)Lorg/reactivestreams/Publisher; createIndexesindexes7Ljava/util/List;l(Ljava/util/List;)Lorg/reactivestreams/Publisher;^(Ljava/util/List;Lcom/mongodb/client/model/CreateIndexOptions;)Lorg/reactivestreams/Publisher;-Lcom/mongodb/client/model/CreateIndexOptions;(Ljava/util/List;Lcom/mongodb/client/model/CreateIndexOptions;)Lorg/reactivestreams/Publisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Ljava/util/List;)Lorg/reactivestreams/Publisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Ljava/util/List;Lcom/mongodb/client/model/CreateIndexOptions;)Lorg/reactivestreams/Publisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Ljava/util/List;Lcom/mongodb/client/model/CreateIndexOptions;)Lorg/reactivestreams/Publisher; listIndexes;()Lcom/mongodb/reactivestreams/client/ListIndexesPublisher;P()Lcom/mongodb/reactivestreams/client/ListIndexesPublisher;L(Ljava/lang/Class;)Lcom/mongodb/reactivestreams/client/ListIndexesPublisher;~(Ljava/lang/Class;)Lcom/mongodb/reactivestreams/client/ListIndexesPublisher;m(Lcom/mongodb/reactivestreams/client/ClientSession;)Lcom/mongodb/reactivestreams/client/ListIndexesPublisher;(Lcom/mongodb/reactivestreams/client/ClientSession;)Lcom/mongodb/reactivestreams/client/ListIndexesPublisher;~(Lcom/mongodb/reactivestreams/client/ClientSession;Ljava/lang/Class;)Lcom/mongodb/reactivestreams/client/ListIndexesPublisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Ljava/lang/Class;)Lcom/mongodb/reactivestreams/client/ListIndexesPublisher; dropIndex3(Ljava/lang/String;)Lorg/reactivestreams/Publisher; indexNameE(Ljava/lang/String;)Lorg/reactivestreams/Publisher;keysN(Lorg/bson/conversions/Bson;)Lorg/reactivestreams/Publisher;^(Ljava/lang/String;Lcom/mongodb/client/model/DropIndexOptions;)Lorg/reactivestreams/Publisher;dropIndexOptions+Lcom/mongodb/client/model/DropIndexOptions;p(Ljava/lang/String;Lcom/mongodb/client/model/DropIndexOptions;)Lorg/reactivestreams/Publisher;g(Lorg/bson/conversions/Bson;Lcom/mongodb/client/model/DropIndexOptions;)Lorg/reactivestreams/Publisher;y(Lorg/bson/conversions/Bson;Lcom/mongodb/client/model/DropIndexOptions;)Lorg/reactivestreams/Publisher;e(Lcom/mongodb/reactivestreams/client/ClientSession;Ljava/lang/String;)Lorg/reactivestreams/Publisher;w(Lcom/mongodb/reactivestreams/client/ClientSession;Ljava/lang/String;)Lorg/reactivestreams/Publisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Lorg/bson/conversions/Bson;)Lorg/reactivestreams/Publisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Ljava/lang/String;Lcom/mongodb/client/model/DropIndexOptions;)Lorg/reactivestreams/Publisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Ljava/lang/String;Lcom/mongodb/client/model/DropIndexOptions;)Lorg/reactivestreams/Publisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Lorg/bson/conversions/Bson;Lcom/mongodb/client/model/DropIndexOptions;)Lorg/reactivestreams/Publisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Lorg/bson/conversions/Bson;Lcom/mongodb/client/model/DropIndexOptions;)Lorg/reactivestreams/Publisher; dropIndexesL(Lcom/mongodb/client/model/DropIndexOptions;)Lorg/reactivestreams/Publisher;^(Lcom/mongodb/client/model/DropIndexOptions;)Lorg/reactivestreams/Publisher;~(Lcom/mongodb/reactivestreams/client/ClientSession;Lcom/mongodb/client/model/DropIndexOptions;)Lorg/reactivestreams/Publisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Lcom/mongodb/client/model/DropIndexOptions;)Lorg/reactivestreams/Publisher;renameCollection=(Lcom/mongodb/MongoNamespace;)Lorg/reactivestreams/Publisher;newCollectionNamespaceLcom/mongodb/MongoNamespace;O(Lcom/mongodb/MongoNamespace;)Lorg/reactivestreams/Publisher;o(Lcom/mongodb/MongoNamespace;Lcom/mongodb/client/model/RenameCollectionOptions;)Lorg/reactivestreams/Publisher;2Lcom/mongodb/client/model/RenameCollectionOptions;(Lcom/mongodb/MongoNamespace;Lcom/mongodb/client/model/RenameCollectionOptions;)Lorg/reactivestreams/Publisher;o(Lcom/mongodb/reactivestreams/client/ClientSession;Lcom/mongodb/MongoNamespace;)Lorg/reactivestreams/Publisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Lcom/mongodb/MongoNamespace;)Lorg/reactivestreams/Publisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Lcom/mongodb/MongoNamespace;Lcom/mongodb/client/model/RenameCollectionOptions;)Lorg/reactivestreams/Publisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Lcom/mongodb/MongoNamespace;Lcom/mongodb/client/model/RenameCollectionOptions;)Lorg/reactivestreams/Publisher;aLjava/lang/Object;Lcom/mongodb/reactivestreams/client/MongoCollection; SourceFileMongoCollectionImpl.java RS TUCcom/mongodb/reactivestreams/client/internal/MongoOperationPublisher ?com/mongodb/reactivestreams/client/internal/MongoCollectionImpl V W X Y Z6com/mongodb/client/model/EstimatedDocumentCountOptions org/bson/BsonDocument %com/mongodb/client/model/CountOptions 0com/mongodb/reactivestreams/client/ClientSession Acom/mongodb/reactivestreams/client/internal/DistinctPublisherImpl [ =com/mongodb/reactivestreams/client/internal/FindPublisherImpl \   Bcom/mongodb/reactivestreams/client/internal/AggregatePublisherImpl] ^_ ` org/bson/Document a bc Ecom/mongodb/reactivestreams/client/internal/ChangeStreamPublisherImpld ^e f  " $)Bcom/mongodb/reactivestreams/client/internal/MapReducePublisherImpl g $-)com/mongodb/client/model/BulkWriteOptions /4 /9)com/mongodb/client/model/InsertOneOptions ;A ;F*com/mongodb/client/model/InsertManyOptions HL HP&com/mongodb/client/model/DeleteOptions RT RX ZT ZX'com/mongodb/client/model/ReplaceOptions [_ [d&com/mongodb/client/model/UpdateOptions fj fo fs fw yj yo ys yw0com/mongodb/client/model/FindOneAndDeleteOptions z| z1com/mongodb/client/model/FindOneAndReplaceOptions  0com/mongodb/client/model/FindOneAndUpdateOptions     h%com/mongodb/client/model/IndexOptions  +com/mongodb/client/model/CreateIndexOptions   Dcom/mongodb/reactivestreams/client/internal/ListIndexesPublisherImpl i )com/mongodb/client/model/DropIndexOptions      0com/mongodb/client/model/RenameCollectionOptions  java/lang/Object2com/mongodb/reactivestreams/client/MongoCollection()V!com/mongodb/assertions/AssertionsnotNull8(Ljava/lang/String;Ljava/lang/Object;)Ljava/lang/Object;X(Ljava/lang/Class;)Lcom/mongodb/reactivestreams/client/internal/MongoOperationPublisher;t(Lorg/bson/codecs/configuration/CodecRegistry;)Lcom/mongodb/reactivestreams/client/internal/MongoOperationPublisher;c(Lcom/mongodb/ReadPreference;)Lcom/mongodb/reactivestreams/client/internal/MongoOperationPublisher;a(Lcom/mongodb/WriteConcern;)Lcom/mongodb/reactivestreams/client/internal/MongoOperationPublisher;`(Lcom/mongodb/ReadConcern;)Lcom/mongodb/reactivestreams/client/internal/MongoOperationPublisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Lcom/mongodb/reactivestreams/client/internal/MongoOperationPublisher;Ljava/lang/String;Lorg/bson/conversions/Bson;)V(Lcom/mongodb/reactivestreams/client/ClientSession;Lcom/mongodb/reactivestreams/client/internal/MongoOperationPublisher;Lorg/bson/conversions/Bson;)V2com/mongodb/internal/client/model/AggregationLevel COLLECTION4Lcom/mongodb/internal/client/model/AggregationLevel;(Lcom/mongodb/reactivestreams/client/ClientSession;Lcom/mongodb/reactivestreams/client/internal/MongoOperationPublisher;Ljava/util/List;Lcom/mongodb/internal/client/model/AggregationLevel;)Vjava/util/Collections emptyList()Ljava/util/List;@com/mongodb/internal/client/model/changestream/ChangeStreamLevelBLcom/mongodb/internal/client/model/changestream/ChangeStreamLevel;(Lcom/mongodb/reactivestreams/client/ClientSession;Lcom/mongodb/reactivestreams/client/internal/MongoOperationPublisher;Ljava/lang/Class;Ljava/util/List;Lcom/mongodb/internal/client/model/changestream/ChangeStreamLevel;)V(Lcom/mongodb/reactivestreams/client/ClientSession;Lcom/mongodb/reactivestreams/client/internal/MongoOperationPublisher;Ljava/lang/String;Ljava/lang/String;)VdropCollectionz(Lcom/mongodb/reactivestreams/client/ClientSession;Lcom/mongodb/reactivestreams/client/internal/MongoOperationPublisher;)V0 j**+FGHD*L  D*Q  D*V  D* [  D* `  D* e  A*i  ` Y*+ nV Y*+s V Y*+x V Y*+} V Y*+ H *Y   O *+   H *Y   S *+Y   [ *+,     S *+Y   ^*+,Y  m* +!,-* h*+Y," w#Y*- +,$*s*+,Y-%*#Y +!* ,-$4L*Y*&'  ] *Y+'  P *+*&'   l(Y*, +) W*+Y*&* h*+Y,* [ *+,*&*     (Y +!*- ,)*Z *+*&+        y,Y*, +-.      e *+,*&/        ,Y +!*- ,-.*     C*01  Y *2+3   X*+03    v4Y*,+56      N*+07 d *+2,8     c *+,08%        !"4Y +!*-,56+*     #$%[ *+,*&91  & '  ($)w:Y*- +,;7*&'*$+f *+,-*&<>*  & '  ,$-:Y +!* ,-;DED4&'./0] *+=Y>?J 1  123/4e *+,@P  1  5 126/7h*+,=Y>AV 1 128/9w* +!,-@]*1 512:;<] *+BYCDb => =?@;Ae *+,Eg  => B =?C;Dh*+,BYCFl =>=?E;Fw* +!,-Er*=>B=?GH0] *+GYHIw I  IJKHLe *+,J|  I  M IJNH7h*+,GYHK I IJOHPw* +!,-J*I MIJQRS *+LYMN   SRT[ *+,O   U  VR^*+,LYMP  WRXm* +!,-O*U YZS *+LYMQ   SZT[ *+,R   U  VZ^*+,LYMS  WZXm* +!,-R*U Y[\h*+,TYUV ]>]?^[_p *+,-W*  ]> ` ]?a[bs*+,-TYUX*]>]?c[d* +!,-W4]>`]?efg^*+,YYZ[ h ifjf *+,-\*  h k  lfmi*+,-YYZ]*h nfoy* +!,-\4hk pfqh*+,YYZ^ h h rfsp *+,-_*  h  k h tfus*+,-YYZ`*h h vfw* +!,-_4h kh xyg^*+,YYZa h iyjf *+,-b*  h k  lymi*+,-YYZc*h nyoy* +!,-b4hk pyqh*+,YYZd h h rysp *+,-e *  h  k h tyus*+,-YYZf*h h vyw* +!,-e4h kh xzS *+gYhi   {z|[ *+,j"   }  ~z^*+,gYhk'  zm* +!,-j-*} \h*+,lYmn2 ]>]?p *+,-o7*  ]>  ]?bs*+,-lYmp<*]>]?* +!,-oB4]>]?g^*+,qYrsG h f *+,-tL*  h   mi*+,-qYruQ*h y* +!,-tW4h qh*+,qYrv\ h h p *+,-wb*  h   h us*+,-qYrxh*h h * +!,-wn4h h E *ys   W* +!yx S *+zY{|}   [ *+,}     ^*+,zY{~  m* +!,-}* 0] *+Y   e *+,     7h*+,Y  w* +!,-* C*0  aY*+ N*+0 {Y +!*,  S *+Y   S *+Y   [ *+,     [ *+,     ^*+,Y  ^*+,Y  m* +!,-* m* +!,-* H *Y   P *+   S *+Y   b* +!,  S *+Y   [ *+,     ^*+,Y  m* +!,-*