4$ Gj  KR G H  G G G GTw G H G[ G G G G !] GX G G G + + + + + + + G +  8   ? G >  G G InnerClassespipelineLjava/util/List; Signature.Ljava/util/List<+Lorg/bson/conversions/Bson;>;codecLorg/bson/codecs/Codec;ZLorg/bson/codecs/Codec;>;changeStreamLevelBLcom/mongodb/internal/client/model/changestream/ChangeStreamLevel; fullDocument4Lcom/mongodb/client/model/changestream/FullDocument; resumeTokenLorg/bson/BsonDocument; startAftermaxAwaitTimeMSJ collation$Lcom/mongodb/client/model/Collation;startAtOperationTimeLorg/bson/BsonTimestamp;(Lcom/mongodb/reactivestreams/client/ClientSession;Lcom/mongodb/reactivestreams/client/internal/MongoOperationPublisher;Ljava/lang/Class;Ljava/util/List;Lcom/mongodb/internal/client/model/changestream/ChangeStreamLevel;)VCodeLineNumberTableLocalVariableTablethisGLcom/mongodb/reactivestreams/client/internal/ChangeStreamPublisherImpl; clientSession2Lcom/mongodb/reactivestreams/client/ClientSession;mongoOperationPublisherELcom/mongodb/reactivestreams/client/internal/MongoOperationPublisher;innerResultClassLjava/lang/Class;LocalVariableTypeTableLLcom/mongodb/reactivestreams/client/internal/ChangeStreamPublisherImpl;HLcom/mongodb/reactivestreams/client/internal/MongoOperationPublisher<*>;Ljava/lang/Class;(Lcom/mongodb/reactivestreams/client/ClientSession;Lcom/mongodb/reactivestreams/client/internal/MongoOperationPublisher<*>;Ljava/lang/Class;Ljava/util/List<+Lorg/bson/conversions/Bson;>;Lcom/mongodb/internal/client/model/changestream/ChangeStreamLevel;)V"RuntimeVisibleParameterAnnotationsLcom/mongodb/lang/Nullable;(Lcom/mongodb/reactivestreams/client/ClientSession;Lcom/mongodb/reactivestreams/client/internal/MongoOperationPublisher;Lorg/bson/codecs/Codec;Ljava/util/List;Lcom/mongodb/internal/client/model/changestream/ChangeStreamLevel;)VG(Lcom/mongodb/reactivestreams/client/ClientSession;Lcom/mongodb/reactivestreams/client/internal/MongoOperationPublisher<*>;Lorg/bson/codecs/Codec;>;Ljava/util/List<+Lorg/bson/conversions/Bson;>;Lcom/mongodb/internal/client/model/changestream/ChangeStreamLevel;)Vp(Lcom/mongodb/client/model/changestream/FullDocument;)Lcom/mongodb/reactivestreams/client/ChangeStreamPublisher;u(Lcom/mongodb/client/model/changestream/FullDocument;)Lcom/mongodb/reactivestreams/client/ChangeStreamPublisher; resumeAfterS(Lorg/bson/BsonDocument;)Lcom/mongodb/reactivestreams/client/ChangeStreamPublisher;X(Lorg/bson/BsonDocument;)Lcom/mongodb/reactivestreams/client/ChangeStreamPublisher; batchSize=(I)Lcom/mongodb/reactivestreams/client/ChangeStreamPublisher;IB(I)Lcom/mongodb/reactivestreams/client/ChangeStreamPublisher; maxAwaitTime\(JLjava/util/concurrent/TimeUnit;)Lcom/mongodb/reactivestreams/client/ChangeStreamPublisher;timeUnitLjava/util/concurrent/TimeUnit;a(JLjava/util/concurrent/TimeUnit;)Lcom/mongodb/reactivestreams/client/ChangeStreamPublisher;`(Lcom/mongodb/client/model/Collation;)Lcom/mongodb/reactivestreams/client/ChangeStreamPublisher;e(Lcom/mongodb/client/model/Collation;)Lcom/mongodb/reactivestreams/client/ChangeStreamPublisher;withDocumentClass2(Ljava/lang/Class;)Lorg/reactivestreams/Publisher;clazzLjava/lang/Class;j(Ljava/lang/Class;)Lorg/reactivestreams/Publisher;T(Lorg/bson/BsonTimestamp;)Lcom/mongodb/reactivestreams/client/ChangeStreamPublisher;Y(Lorg/bson/BsonTimestamp;)Lcom/mongodb/reactivestreams/client/ChangeStreamPublisher;`(Lorg/bson/BsonDocument;)Lcom/mongodb/reactivestreams/client/internal/ChangeStreamPublisherImpl;e(Lorg/bson/BsonDocument;)Lcom/mongodb/reactivestreams/client/internal/ChangeStreamPublisherImpl;asAsyncReadOperation6(I)Lcom/mongodb/internal/operation/AsyncReadOperation;initialBatchSize(I)Lcom/mongodb/internal/operation/AsyncReadOperation;>;>;createChangeStreamOperationM(Lorg/bson/codecs/Codec;I)Lcom/mongodb/internal/operation/AsyncReadOperation;Lorg/bson/codecs/Codec;(Lorg/bson/codecs/Codec;I)Lcom/mongodb/internal/operation/AsyncReadOperation;>;createBsonDocumentList"(Ljava/util/List;)Ljava/util/List;objLorg/bson/conversions/Bson; aggregateList)Ljava/util/List; StackMapTableY(Ljava/util/List<+Lorg/bson/conversions/Bson;>;)Ljava/util/List;"(I)Lorg/reactivestreams/Publisher; access$000(Lcom/mongodb/reactivestreams/client/internal/ChangeStreamPublisherImpl;Lorg/bson/codecs/Codec;I)Lcom/mongodb/internal/operation/AsyncReadOperation;x0x1x2Lcom/mongodb/reactivestreams/client/internal/BatchCursorPublisher;>;Lcom/mongodb/reactivestreams/client/ChangeStreamPublisher; SourceFileChangeStreamPublisherImpl.java  java/lang/Class  java/util/List@com/mongodb/internal/client/model/changestream/ChangeStreamLevel _s _ U TU KL OP RS2com/mongodb/client/model/changestream/FullDocumentorg/bson/BsonDocument VW z  YZ"com/mongodb/client/model/Collation [\Gcom/mongodb/reactivestreams/client/internal/ChangeStreamPublisherImpl$1    _org/bson/BsonTimestamp ]^ XW4com/mongodb/internal/operation/ChangeStreamOperation  _    z [ ~ w ] X  java/util/ArrayList  _   org/bson/conversions/Bson"java/lang/IllegalArgumentException%pipeline can not contain a null value _  ! "# z{ XEcom/mongodb/reactivestreams/client/internal/ChangeStreamPublisherImpl@com/mongodb/reactivestreams/client/internal/BatchCursorPublisher8com/mongodb/reactivestreams/client/ChangeStreamPublisherjava/util/Iterator!com/mongodb/assertions/AssertionsnotNull8(Ljava/lang/String;Ljava/lang/Object;)Ljava/lang/Object;Ccom/mongodb/reactivestreams/client/internal/MongoOperationPublishergetCodecRegistry/()Lorg/bson/codecs/configuration/CodecRegistry;:com/mongodb/client/model/changestream/ChangeStreamDocument createCodecW(Ljava/lang/Class;Lorg/bson/codecs/configuration/CodecRegistry;)Lorg/bson/codecs/Codec;org/bson/codecs/CodecgetEncoderClass()Ljava/lang/Class;X(Ljava/lang/Class;)Lcom/mongodb/reactivestreams/client/internal/MongoOperationPublisher;z(Lcom/mongodb/reactivestreams/client/ClientSession;Lcom/mongodb/reactivestreams/client/internal/MongoOperationPublisher;)VDEFAULTjava/util/concurrent/TimeUnit MILLISECONDSconvert#(JLjava/util/concurrent/TimeUnit;)JgetClientSession4()Lcom/mongodb/reactivestreams/client/ClientSession;getMongoOperationPublisherG()Lcom/mongodb/reactivestreams/client/internal/MongoOperationPublisher; getBatchSize()Ljava/lang/Integer;(Lcom/mongodb/reactivestreams/client/internal/ChangeStreamPublisherImpl;Lcom/mongodb/reactivestreams/client/ClientSession;Lcom/mongodb/reactivestreams/client/internal/MongoOperationPublisher;Ljava/lang/Integer;Ljava/lang/Class;)V getNamespace()Lcom/mongodb/MongoNamespace;(Lcom/mongodb/MongoNamespace;Lcom/mongodb/client/model/changestream/FullDocument;Ljava/util/List;Lorg/bson/codecs/Decoder;Lcom/mongodb/internal/client/model/changestream/ChangeStreamLevel;)Vjava/lang/IntegervalueOf(I)Ljava/lang/Integer;K(Ljava/lang/Integer;)Lcom/mongodb/internal/operation/ChangeStreamOperation;\(Lcom/mongodb/client/model/Collation;)Lcom/mongodb/internal/operation/ChangeStreamOperation;X(JLjava/util/concurrent/TimeUnit;)Lcom/mongodb/internal/operation/ChangeStreamOperation;O(Lorg/bson/BsonDocument;)Lcom/mongodb/internal/operation/ChangeStreamOperation;P(Lorg/bson/BsonTimestamp;)Lcom/mongodb/internal/operation/ChangeStreamOperation; getRetryReads()Z retryReads9(Z)Lcom/mongodb/internal/operation/ChangeStreamOperation;size()I(I)Viterator()Ljava/util/Iterator;hasNextnext()Ljava/lang/Object;(Ljava/lang/String;)VtoBsonDocumentW(Ljava/lang/Class;Lorg/bson/codecs/configuration/CodecRegistry;)Lorg/bson/BsonDocument;add(Ljava/lang/Object;)Z0GHI KLMNOPMQRSTUVWXWYZ[\]^_`a+*+,-,  b@A BAC'@*Dc>+de+fg+hi+jk+KL+RSl*+dm+hn+jo+KNMpqr_sa(*+,-  ***-*bL3MN!O'Pc>(de(fg(hi(OP(KL(RSl*(dm(hn(OQ(KNMtqrTuaY*+*b T UcdeTUl dmMvwxaY*+*b Z [cdewWl dmMyz{aR*W*b `acdez|l dmM}~am-W*-*bfghc de~Zl dmM[aY*+ *b m ncde[\l dmMqrar!Y**"*#+ *$+%bstscdekldmM]aY*&+'(*b ~ cde]^l dmMXaY*)+**b  cdeXWl dmMaP **bc de |l  dmMaQ+Y*,***-+*./0* 1*2*3*(4**5*67b* '18?FJPc QdeQOPQ|lQdmQOMaQ8Y+9:M+;N-<4-=>: ?Y@A,*BCDW,b).8LOc*)#QdeQKLCLl QdmQKNC">MAzaB*Eb,c del dmAXxaB*+Fb,c del dmaE*+b,c eP|MJ !