4h H                          $       - v   5        =! " #$ %& B' () *+,mongoOperationPublisherELcom/mongodb/reactivestreams/client/internal/MongoOperationPublisher; SignatureZLcom/mongodb/reactivestreams/client/internal/MongoOperationPublisher;H(Lcom/mongodb/reactivestreams/client/internal/MongoOperationPublisher;)VCodeLineNumberTableLocalVariableTablethis?Lcom/mongodb/reactivestreams/client/internal/MongoDatabaseImpl;LocalVariableTypeTable](Lcom/mongodb/reactivestreams/client/internal/MongoOperationPublisher;)VgetName()Ljava/lang/String;getCodecRegistry/()Lorg/bson/codecs/configuration/CodecRegistry;getReadPreference()Lcom/mongodb/ReadPreference;getWriteConcern()Lcom/mongodb/WriteConcern;getReadConcern()Lcom/mongodb/ReadConcern;getMongoOperationPublisherG()Lcom/mongodb/reactivestreams/client/internal/MongoOperationPublisher;\()Lcom/mongodb/reactivestreams/client/internal/MongoOperationPublisher;withCodecRegistrya(Lorg/bson/codecs/configuration/CodecRegistry;)Lcom/mongodb/reactivestreams/client/MongoDatabase; codecRegistry-Lorg/bson/codecs/configuration/CodecRegistry;withReadPreferenceP(Lcom/mongodb/ReadPreference;)Lcom/mongodb/reactivestreams/client/MongoDatabase;readPreferenceLcom/mongodb/ReadPreference;withWriteConcernN(Lcom/mongodb/WriteConcern;)Lcom/mongodb/reactivestreams/client/MongoDatabase; writeConcernLcom/mongodb/WriteConcern;withReadConcernM(Lcom/mongodb/ReadConcern;)Lcom/mongodb/reactivestreams/client/MongoDatabase; readConcernLcom/mongodb/ReadConcern; getCollectionH(Ljava/lang/String;)Lcom/mongodb/reactivestreams/client/MongoCollection;collectionNameLjava/lang/String;](Ljava/lang/String;)Lcom/mongodb/reactivestreams/client/MongoCollection;Y(Ljava/lang/String;Ljava/lang/Class;)Lcom/mongodb/reactivestreams/client/MongoCollection;clazzLjava/lang/Class;Ljava/lang/Class;y(Ljava/lang/String;Ljava/lang/Class;)Lcom/mongodb/reactivestreams/client/MongoCollection; runCommand<(Lorg/bson/conversions/Bson;)Lorg/reactivestreams/Publisher;commandLorg/bson/conversions/Bson;Q(Lorg/bson/conversions/Bson;)Lorg/reactivestreams/Publisher;X(Lorg/bson/conversions/Bson;Lcom/mongodb/ReadPreference;)Lorg/reactivestreams/Publisher;m(Lorg/bson/conversions/Bson;Lcom/mongodb/ReadPreference;)Lorg/reactivestreams/Publisher;M(Lorg/bson/conversions/Bson;Ljava/lang/Class;)Lorg/reactivestreams/Publisher;m(Lorg/bson/conversions/Bson;Ljava/lang/Class;)Lorg/reactivestreams/Publisher;i(Lorg/bson/conversions/Bson;Lcom/mongodb/ReadPreference;Ljava/lang/Class;)Lorg/reactivestreams/Publisher;(Lorg/bson/conversions/Bson;Lcom/mongodb/ReadPreference;Ljava/lang/Class;)Lorg/reactivestreams/Publisher;n(Lcom/mongodb/reactivestreams/client/ClientSession;Lorg/bson/conversions/Bson;)Lorg/reactivestreams/Publisher; clientSession2Lcom/mongodb/reactivestreams/client/ClientSession;(Lcom/mongodb/reactivestreams/client/ClientSession;Lorg/bson/conversions/Bson;)Lorg/reactivestreams/Publisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Lorg/bson/conversions/Bson;Lcom/mongodb/ReadPreference;)Lorg/reactivestreams/Publisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Lorg/bson/conversions/Bson;Lcom/mongodb/ReadPreference;)Lorg/reactivestreams/Publisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Lorg/bson/conversions/Bson;Ljava/lang/Class;)Lorg/reactivestreams/Publisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Lorg/bson/conversions/Bson;Ljava/lang/Class;)Lorg/reactivestreams/Publisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Lorg/bson/conversions/Bson;Lcom/mongodb/ReadPreference;Ljava/lang/Class;)Lorg/reactivestreams/Publisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Lorg/bson/conversions/Bson;Lcom/mongodb/ReadPreference;Ljava/lang/Class;)Lorg/reactivestreams/Publisher;drop!()Lorg/reactivestreams/Publisher;3()Lorg/reactivestreams/Publisher;S(Lcom/mongodb/reactivestreams/client/ClientSession;)Lorg/reactivestreams/Publisher;e(Lcom/mongodb/reactivestreams/client/ClientSession;)Lorg/reactivestreams/Publisher;listCollectionNames5()Lorg/reactivestreams/Publisher;g(Lcom/mongodb/reactivestreams/client/ClientSession;)Lorg/reactivestreams/Publisher;listCollections?()Lcom/mongodb/reactivestreams/client/ListCollectionsPublisher;T()Lcom/mongodb/reactivestreams/client/ListCollectionsPublisher;P(Ljava/lang/Class;)Lcom/mongodb/reactivestreams/client/ListCollectionsPublisher;Ljava/lang/Class;p(Ljava/lang/Class;)Lcom/mongodb/reactivestreams/client/ListCollectionsPublisher;q(Lcom/mongodb/reactivestreams/client/ClientSession;)Lcom/mongodb/reactivestreams/client/ListCollectionsPublisher;(Lcom/mongodb/reactivestreams/client/ClientSession;)Lcom/mongodb/reactivestreams/client/ListCollectionsPublisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Ljava/lang/Class;)Lcom/mongodb/reactivestreams/client/ListCollectionsPublisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Ljava/lang/Class;)Lcom/mongodb/reactivestreams/client/ListCollectionsPublisher;createCollection3(Ljava/lang/String;)Lorg/reactivestreams/Publisher;E(Ljava/lang/String;)Lorg/reactivestreams/Publisher;e(Ljava/lang/String;Lcom/mongodb/client/model/CreateCollectionOptions;)Lorg/reactivestreams/Publisher;options2Lcom/mongodb/client/model/CreateCollectionOptions;w(Ljava/lang/String;Lcom/mongodb/client/model/CreateCollectionOptions;)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;Ljava/lang/String;Lcom/mongodb/client/model/CreateCollectionOptions;)Lorg/reactivestreams/Publisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Ljava/lang/String;Lcom/mongodb/client/model/CreateCollectionOptions;)Lorg/reactivestreams/Publisher; createViewU(Ljava/lang/String;Ljava/lang/String;Ljava/util/List;)Lorg/reactivestreams/Publisher;viewNameviewOnpipelineLjava/util/List;.Ljava/util/List<+Lorg/bson/conversions/Bson;>;(Ljava/lang/String;Ljava/lang/String;Ljava/util/List<+Lorg/bson/conversions/Bson;>;)Lorg/reactivestreams/Publisher;(Ljava/lang/String;Ljava/lang/String;Ljava/util/List;Lcom/mongodb/client/model/CreateViewOptions;)Lorg/reactivestreams/Publisher;,Lcom/mongodb/client/model/CreateViewOptions;(Ljava/lang/String;Ljava/lang/String;Ljava/util/List<+Lorg/bson/conversions/Bson;>;Lcom/mongodb/client/model/CreateViewOptions;)Lorg/reactivestreams/Publisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Ljava/lang/String;Ljava/lang/String;Ljava/util/List;)Lorg/reactivestreams/Publisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Ljava/lang/String;Ljava/lang/String;Ljava/util/List<+Lorg/bson/conversions/Bson;>;)Lorg/reactivestreams/Publisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Ljava/lang/String;Ljava/lang/String;Ljava/util/List;Lcom/mongodb/client/model/CreateViewOptions;)Lorg/reactivestreams/Publisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Ljava/lang/String;Ljava/lang/String;Ljava/util/List<+Lorg/bson/conversions/Bson;>;Lcom/mongodb/client/model/CreateViewOptions;)Lorg/reactivestreams/Publisher;watch<()Lcom/mongodb/reactivestreams/client/ChangeStreamPublisher;Q()Lcom/mongodb/reactivestreams/client/ChangeStreamPublisher;M(Ljava/lang/Class;)Lcom/mongodb/reactivestreams/client/ChangeStreamPublisher; resultClassm(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; aggregateI(Ljava/util/List;)Lcom/mongodb/reactivestreams/client/AggregatePublisher;|(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;lambda$listCollectionNames$1'(Lorg/bson/Document;)Ljava/lang/String;dLorg/bson/Document;lambda$listCollectionNames$0 SourceFileMongoDatabaseImpl.java N-publisherHelper. /0Ccom/mongodb/reactivestreams/client/internal/MongoOperationPublisher JK WX 12 34 5X YZ [\ ]^ _`=com/mongodb/reactivestreams/client/internal/MongoDatabaseImpl d6 NO h7 l8 p9org/bson/Document ty?com/mongodb/reactivestreams/client/internal/MongoCollectionImplcom/mongodb/MongoNamespace N: ;< ~ ~= >\ ~ ~0com/mongodb/reactivestreams/client/ClientSession ?Hcom/mongodb/reactivestreams/client/internal/ListCollectionsPublisherImpl N@A BCBootstrapMethodsDEF GH IJK LM 0com/mongodb/client/model/CreateCollectionOptions java/lang/String N *com/mongodb/client/model/CreateViewOptions O PQ Ecom/mongodb/reactivestreams/client/internal/ChangeStreamPublisherImplR ST NU Bcom/mongodb/reactivestreams/client/internal/AggregatePublisherImplV SW NX name YZjava/lang/Object0com/mongodb/reactivestreams/client/MongoDatabase()V!com/mongodb/assertions/AssertionsnotNull8(Ljava/lang/String;Ljava/lang/Object;)Ljava/lang/Object;checkDatabaseNameValidity(Ljava/lang/String;)V getNamespace()Lcom/mongodb/MongoNamespace;getDatabaseNamet(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;'(Ljava/lang/String;Ljava/lang/String;)VwithNamespaceAndDocumentClasst(Lcom/mongodb/MongoNamespace;Ljava/lang/Class;)Lcom/mongodb/reactivestreams/client/internal/MongoOperationPublisher;com/mongodb/ReadPreferenceprimary dropDatabase{(Lcom/mongodb/reactivestreams/client/ClientSession;Lcom/mongodb/reactivestreams/client/internal/MongoOperationPublisher;Z)Vreactor/core/publisher/Fluxfrom>(Lorg/reactivestreams/Publisher;)Lreactor/core/publisher/Flux; [\&(Ljava/lang/Object;)Ljava/lang/Object; ]apply()Ljava/util/function/Function;map<(Ljava/util/function/Function;)Lreactor/core/publisher/Flux; ^withDocumentClassX(Ljava/lang/Class;)Lcom/mongodb/reactivestreams/client/internal/MongoOperationPublisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Lcom/mongodb/MongoNamespace;Lcom/mongodb/client/model/CreateCollectionOptions;)Lorg/reactivestreams/Publisher;java/util/Collections emptyList()Ljava/util/List;@com/mongodb/internal/client/model/changestream/ChangeStreamLevelDATABASEBLcom/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;)V2com/mongodb/internal/client/model/AggregationLevel4Lcom/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;)V getString&(Ljava/lang/Object;)Ljava/lang/String;_ `d "java/lang/invoke/LambdaMetafactory metafactoryfLookup InnerClasses(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;g%java/lang/invoke/MethodHandles$Lookupjava/lang/invoke/MethodHandles1HIJKLM3NOPk**+*Q6789RSTJKU JMLVWXP5 * Q=R  STYZP2* QBR ST[\P2* QGR ST]^P2* QLR ST_`P2* QQR STabP/*QUR STLcdePDY*+QZRSTfghiPDY*+Q_RSTjklmPDY*+QdRSTnopqPDY*+QiRSTrstuP<*+QnRSTvwLxtyPtY*Y*+,Qs tsR STvwz{U z|L}~P<*+QyRSTL~PG *+,Q~R  ST  jkL~PZ *+,QR  ST  z{U  z|L~Pf *+,-QR* ST  jk z{U  z|L~PG *+,QR  ST  L~PR *+,- QR* ST   jkL~Pe *+,- QR* ST   z{U  z|L~Py*!+",-QR4STjkz{U z|LP3 *#QR  STLPE*!+"#QRSTLPK$Y*%&'(QR STLP]!$Y!+"*%&)(Q R!ST!LP1**QR STLPX$Y*++%QRSTz{U zLP<*+,QRSTLPr$Y!+"*,+%QR STz{U zLPA *+-Y./QR ST vwLPp&*Y*0+12,-3Q "R &ST&vw&LPL*+,-Y.4QR STvwLP.*!+"Y*0,12--3Q$*R*.ST..vw.LPi*+,-5Y67QR*STwwU LPr*+,-8QR4STwwU LPu*+,-5Y69QR4STwwU LP*!+",-8QR>STwwU LP2*:;QR STLPO *:+<QR ST {U  |LPN*+<QRSTU LPl=Y*,+>?Q R ST{U|LP? *+:@QR ST LPZ *+:,@QR  ST  {U  |LPY *+,@QR  ST  U  LP~=Y!+"*-,>?Q!R*ST{U|LPN*+AQ'RSTU LPoBY*,++CDQ,R ST{U|LPY *+,EQ2R  ST  U  LPBY!+"*-+,CDQ898R*ST{U|L P1*FGQR  P1*FGQR c aeb