4 XZ  W^ W W X W W W W W W W W .  W W  W W W ) ) ) W . W  2 W        W < W C .  . P C  . . . ! P ."# W$ %& '()*+pipelineLjava/util/List; Signature.Ljava/util/List<+Lorg/bson/conversions/Bson;>;aggregationLevel4Lcom/mongodb/internal/client/model/AggregationLevel; allowDiskUseLjava/lang/Boolean; maxTimeMSJmaxAwaitTimeMSbypassDocumentValidation collation$Lcom/mongodb/client/model/Collation;commentLjava/lang/String;hintLorg/bson/conversions/Bson; variables(Lcom/mongodb/reactivestreams/client/ClientSession;Lcom/mongodb/reactivestreams/client/internal/MongoOperationPublisher;Ljava/util/List;Lcom/mongodb/internal/client/model/AggregationLevel;)VCodeLineNumberTableLocalVariableTablethisDLcom/mongodb/reactivestreams/client/internal/AggregatePublisherImpl; clientSession2Lcom/mongodb/reactivestreams/client/ClientSession;mongoOperationPublisherELcom/mongodb/reactivestreams/client/internal/MongoOperationPublisher;LocalVariableTypeTableILcom/mongodb/reactivestreams/client/internal/AggregatePublisherImpl;JLcom/mongodb/reactivestreams/client/internal/MongoOperationPublisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Lcom/mongodb/reactivestreams/client/internal/MongoOperationPublisher;Ljava/util/List<+Lorg/bson/conversions/Bson;>;Lcom/mongodb/internal/client/model/AggregationLevel;)V"RuntimeVisibleParameterAnnotationsLcom/mongodb/lang/Nullable;L(Ljava/lang/Boolean;)Lcom/mongodb/reactivestreams/client/AggregatePublisher;Q(Ljava/lang/Boolean;)Lcom/mongodb/reactivestreams/client/AggregatePublisher; batchSize:(I)Lcom/mongodb/reactivestreams/client/AggregatePublisher;I?(I)Lcom/mongodb/reactivestreams/client/AggregatePublisher;maxTimeY(JLjava/util/concurrent/TimeUnit;)Lcom/mongodb/reactivestreams/client/AggregatePublisher;timeUnitLjava/util/concurrent/TimeUnit;^(JLjava/util/concurrent/TimeUnit;)Lcom/mongodb/reactivestreams/client/AggregatePublisher; maxAwaitTime](Lcom/mongodb/client/model/Collation;)Lcom/mongodb/reactivestreams/client/AggregatePublisher;b(Lcom/mongodb/client/model/Collation;)Lcom/mongodb/reactivestreams/client/AggregatePublisher;K(Ljava/lang/String;)Lcom/mongodb/reactivestreams/client/AggregatePublisher;P(Ljava/lang/String;)Lcom/mongodb/reactivestreams/client/AggregatePublisher;T(Lorg/bson/conversions/Bson;)Lcom/mongodb/reactivestreams/client/AggregatePublisher;Y(Lorg/bson/conversions/Bson;)Lcom/mongodb/reactivestreams/client/AggregatePublisher;let toCollection!()Lorg/reactivestreams/Publisher;lastPipelineStageLorg/bson/BsonDocument; StackMapTable3()Lorg/reactivestreams/Publisher;explain6()Lorg/reactivestreams/Publisher;?(Lcom/mongodb/ExplainVerbosity;)Lorg/reactivestreams/Publisher; verbosityLcom/mongodb/ExplainVerbosity;T(Lcom/mongodb/ExplainVerbosity;)Lorg/reactivestreams/Publisher;2(Ljava/lang/Class;)Lorg/reactivestreams/Publisher;explainResultClassLjava/lang/Class;Ljava/lang/Class;R(Ljava/lang/Class;)Lorg/reactivestreams/Publisher;P(Ljava/lang/Class;Lcom/mongodb/ExplainVerbosity;)Lorg/reactivestreams/Publisher;p(Ljava/lang/Class;Lcom/mongodb/ExplainVerbosity;)Lorg/reactivestreams/Publisher;publishExplainasAsyncReadOperation6(I)Lcom/mongodb/internal/operation/AsyncReadOperation;aggregateToCollectionOperation4Lcom/mongodb/internal/operation/AsyncWriteOperation; findOptions/Lcom/mongodb/internal/client/model/FindOptions; findOperation3Lcom/mongodb/internal/operation/AsyncReadOperation;initialBatchSize outNamespaceLcom/mongodb/MongoNamespace;FLcom/mongodb/internal/operation/AsyncWriteOperation;gLcom/mongodb/internal/operation/AsyncReadOperation;>;j(I)Lcom/mongodb/internal/operation/AsyncReadOperation;>;asAggregateOperation6(I)Lcom/mongodb/internal/operation/AggregateOperation;;(I)Lcom/mongodb/internal/operation/AggregateOperation;!getAggregateToCollectionOperation6()Lcom/mongodb/internal/operation/AsyncWriteOperation;H()Lcom/mongodb/internal/operation/AsyncWriteOperation;getLastPipelineStage()Lorg/bson/BsonDocument; lastStageRuntimeVisibleAnnotationsgetOutNamespace()Lcom/mongodb/MongoNamespace; outDocument intoDocument mergeDocument databaseName,"(I)Lorg/reactivestreams/Publisher;lambda$publishExplain$0d(Lcom/mongodb/ExplainVerbosity;Ljava/lang/Class;)Lcom/mongodb/internal/operation/AsyncReadOperation;Lcom/mongodb/reactivestreams/client/internal/BatchCursorPublisher;Lcom/mongodb/reactivestreams/client/AggregatePublisher; SourceFileAggregatePublisherImpl.java m-. /0java/util/List Z[2com/mongodb/internal/client/model/AggregationLevel ^_ `a 1 2 34 bc dc ea fg hi jk lk $out 56$mergejava/lang/IllegalStateExceptionAThe last stage of the aggregation pipeline must be $out or $merge m7 89BootstrapMethods:;( <= >?@ ABorg/bson/Document com/mongodb/ExplainVerbosityexplainDocumentClassCD <E FB -com/mongodb/internal/client/model/FindOptions mG fH I JKorg/bson/BsonDocument LMN OPQcom/mongodb/reactivestreams/client/internal/WriteOperationThenCursorReadOperation mQ R ST UV WX YZlast pipeline stage [\ <]org/bson/conversions/Bson ^_ `a b cd <ef gZcom/mongodb/MongoNamespace hi jd mk lZ mndbcollPCannot return a cursor when the value for $out stage is not a namespace documentZCannot return a cursor when the value for $out stage is not a string or namespace document g6 l6intoorg/bson/BsonString hoTCannot return a cursor when the value for $merge stage is not a string or a document p <qr stBcom/mongodb/reactivestreams/client/internal/AggregatePublisherImpl@com/mongodb/reactivestreams/client/internal/BatchCursorPublisher5com/mongodb/reactivestreams/client/AggregatePublisherjava/lang/Stringz(Lcom/mongodb/reactivestreams/client/ClientSession;Lcom/mongodb/reactivestreams/client/internal/MongoOperationPublisher;)V!com/mongodb/assertions/AssertionsnotNull8(Ljava/lang/String;Ljava/lang/Object;)Ljava/lang/Object;java/util/concurrent/TimeUnit MILLISECONDSconvert#(JLjava/util/concurrent/TimeUnit;)J containsKey(Ljava/lang/Object;)Z(Ljava/lang/String;)VgetMongoOperationPublisherG()Lcom/mongodb/reactivestreams/client/internal/MongoOperationPublisher; uv()Ljava/lang/Object;getc(Lcom/mongodb/reactivestreams/client/internal/AggregatePublisherImpl;)Ljava/util/function/Supplier;getClientSession4()Lcom/mongodb/reactivestreams/client/ClientSession;Ccom/mongodb/reactivestreams/client/internal/MongoOperationPublishercreateWriteOperationMonon(Ljava/util/function/Supplier;Lcom/mongodb/reactivestreams/client/ClientSession;)Lreactor/core/publisher/Mono; Ww5()Lcom/mongodb/internal/operation/AsyncReadOperation;(Lcom/mongodb/reactivestreams/client/internal/AggregatePublisherImpl;Lcom/mongodb/ExplainVerbosity;Ljava/lang/Class;)Ljava/util/function/Supplier;createReadOperationMono()VU(Lcom/mongodb/client/model/Collation;)Lcom/mongodb/internal/client/model/FindOptions;2(I)Lcom/mongodb/internal/client/model/FindOptions; getOperations-()Lcom/mongodb/internal/operation/Operations;getDocumentClass()Ljava/lang/Class;)com/mongodb/internal/operation/Operationsfind(Lcom/mongodb/MongoNamespace;Lorg/bson/conversions/Bson;Ljava/lang/Class;Lcom/mongodb/internal/client/model/FindOptions;)Lcom/mongodb/internal/operation/FindOperation;j(Lcom/mongodb/internal/operation/AsyncWriteOperation;Lcom/mongodb/internal/operation/AsyncReadOperation;)Vjava/lang/IntegervalueOf(I)Ljava/lang/Integer; aggregate(Ljava/util/List;Ljava/lang/Class;JJLjava/lang/Integer;Lcom/mongodb/client/model/Collation;Lorg/bson/conversions/Bson;Ljava/lang/String;Lorg/bson/conversions/Bson;Ljava/lang/Boolean;Lcom/mongodb/internal/client/model/AggregationLevel;)Lcom/mongodb/internal/operation/AggregateOperation;aggregateToCollection(Ljava/util/List;JLjava/lang/Boolean;Ljava/lang/Boolean;Lcom/mongodb/client/model/Collation;Lorg/bson/conversions/Bson;Ljava/lang/String;Lorg/bson/conversions/Bson;Lcom/mongodb/internal/client/model/AggregationLevel;)Lcom/mongodb/internal/operation/AggregateToCollectionOperation;isEmpty()Zsize()I(I)Ljava/lang/Object;getCodecRegistry/()Lorg/bson/codecs/configuration/CodecRegistry;toBsonDocumentW(Ljava/lang/Class;Lorg/bson/codecs/configuration/CodecRegistry;)Lorg/bson/BsonDocument; getNamespacegetDatabaseName()Ljava/lang/String;((Ljava/lang/Object;)Lorg/bson/BsonValue;org/bson/BsonValueisString getString)(Ljava/lang/Object;)Lorg/bson/BsonString;getValue'(Ljava/lang/String;Ljava/lang/String;)V isDocument getDocument+(Ljava/lang/Object;)Lorg/bson/BsonDocument;>(Ljava/lang/Object;Lorg/bson/BsonString;)Lorg/bson/BsonString;+org/bson/codecs/configuration/CodecRegistry*(Ljava/lang/Class;)Lorg/bson/codecs/Codec;1com/mongodb/internal/operation/AggregateOperationasAsyncExplainableOperationl(Lcom/mongodb/ExplainVerbosity;Lorg/bson/codecs/Decoder;)Lcom/mongodb/internal/operation/AsyncReadOperation;x y} "java/lang/invoke/LambdaMetafactory metafactoryLookup 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;%java/lang/invoke/MethodHandles$Lookupjava/lang/invoke/MethodHandles0WXY Z[\]^_`abcdceafghijklkmno"*+,*-*p;<=!>q4"rs"tu"vw"Z["^_x "ry"vz"Z]\{| }`~oQ*+ *p BCqrs`ax ry\|}oR* W*p HIqrsx ry\om -W* - *pNOPq rscx ry\om -W* - *pUVWq rscx ry\e~oQ*+*p \]qrseax ry\|}foQ*+*p bcqrsfgx ry\|}hoQ*+*p hiqrshix ry\|}joQ*+*p noqrsjkx ry\|}oQ*+*p tuqrslkx ry\|}o7*L+++ Y***pz{|%~q7rs2x 7ry . \oD* !pq rsx ry\oV* "+#!pqrsx ry\oW*+!pqrsxry\oi*+",#!pq rsxry\o$+W**,+%*&pq rsxry\| }oJ*'M,>*(N)Y**+,:*-,.Y/*01:2Y-3*4p" "#9Dq>6""9 JrsJEx 69 JryDC\o4*-**0**5***** *6p 03q4rs4x 4ry\oh ,*-*** ******7pq ,rsx ,ry\o=*89**:d;<p .q.k=rsx =ry}o% *L+*?@M+t+ABCY,+DEF+AG@+HN-I -J YKCY-IDE-JDEFYL++MCY,+DEF+N]+HN-ON/-OH:CYIPY,QREJDEF-OMCY,-ODEF YSpr (:FM_iq>M6$P rs ix  ry% ..$.  #D. }AoB*Tp*q rsx ryol*4+*=,UVpq rsx ry\| z~{