4C * + , - ./ 01 (234 val$clazzLjava/lang/Class;this$0GLcom/mongodb/reactivestreams/client/internal/ChangeStreamPublisherImpl;(Lcom/mongodb/reactivestreams/client/internal/ChangeStreamPublisherImpl;Lcom/mongodb/reactivestreams/client/ClientSession;Lcom/mongodb/reactivestreams/client/internal/MongoOperationPublisher;Ljava/lang/Integer;Ljava/lang/Class;)VCodeLineNumberTableLocalVariableTablethis InnerClassesILcom/mongodb/reactivestreams/client/internal/ChangeStreamPublisherImpl$1; clientSession2Lcom/mongodb/reactivestreams/client/ClientSession;mongoOperationPublisherELcom/mongodb/reactivestreams/client/internal/MongoOperationPublisher; batchSizeLjava/lang/Integer;LocalVariableTypeTableRLcom/mongodb/reactivestreams/client/internal/MongoOperationPublisher;asAsyncReadOperation6(I)Lcom/mongodb/internal/operation/AsyncReadOperation;initialBatchSizeI Signaturer(I)Lcom/mongodb/internal/operation/AsyncReadOperation;>;OLcom/mongodb/reactivestreams/client/internal/BatchCursorPublisher; SourceFileChangeStreamPublisherImpl.javaEnclosingMethod5 67 8 9:; <=> ?@ ABGcom/mongodb/reactivestreams/client/internal/ChangeStreamPublisherImpl$1@com/mongodb/reactivestreams/client/internal/BatchCursorPublisherEcom/mongodb/reactivestreams/client/internal/ChangeStreamPublisherImplwithDocumentClass2(Ljava/lang/Class;)Lorg/reactivestreams/Publisher;(Lcom/mongodb/reactivestreams/client/ClientSession;Lcom/mongodb/reactivestreams/client/internal/MongoOperationPublisher;Ljava/lang/Integer;)VgetMongoOperationPublisherG()Lcom/mongodb/reactivestreams/client/internal/MongoOperationPublisher;Ccom/mongodb/reactivestreams/client/internal/MongoOperationPublishergetCodecRegistry/()Lorg/bson/codecs/configuration/CodecRegistry;+org/bson/codecs/configuration/CodecRegistryget*(Ljava/lang/Class;)Lorg/bson/codecs/Codec; access$000(Lcom/mongodb/reactivestreams/client/internal/ChangeStreamPublisherImpl;Lorg/bson/codecs/Codec;I)Lcom/mongodb/internal/operation/AsyncReadOperation;    *+**,-t4 _***w ! "#"$%&'()