2 3  4 4   4 4 4 4 4 4 4  4 4 4 4 4 4 4  4 4 4 4 4 4 4 4 4 4 4 4 4     MAX_LOOK_AHEAD_STEPI producerIndex(Ljava/util/concurrent/atomic/AtomicLong;producerLookAheadStepproducerLookAheadJ producerMaskproducerBuffer2Ljava/util/concurrent/atomic/AtomicReferenceArray; SignatureFLjava/util/concurrent/atomic/AtomicReferenceArray; consumerMaskconsumerBuffer consumerIndexHAS_NEXTLjava/lang/Object;(I)VCodeLineNumberTableLocalVariableTablethis2Lio/reactivex/internal/queue/SpscLinkedArrayQueue; bufferSize p2capacitymaskbufferLocalVariableTypeTable7Lio/reactivex/internal/queue/SpscLinkedArrayQueue;offer(Ljava/lang/Object;)Z lookAheadSteplookAheadElementOffseteindexoffsetTT; StackMapTable(TT;)Z writeToQueueI(Ljava/util/concurrent/atomic/AtomicReferenceArray;Ljava/lang/Object;JI)ZN(Ljava/util/concurrent/atomic/AtomicReferenceArray;TT;JI)ZresizeJ(Ljava/util/concurrent/atomic/AtomicReferenceArray;JILjava/lang/Object;J)V oldBuffer currIndexcapacity newBufferO(Ljava/util/concurrent/atomic/AtomicReferenceArray;JITT;J)VsoNextg(Ljava/util/concurrent/atomic/AtomicReferenceArray;Ljava/util/concurrent/atomic/AtomicReferenceArray;)Vcurrnext(Ljava/util/concurrent/atomic/AtomicReferenceArray;Ljava/util/concurrent/atomic/AtomicReferenceArray;)VlvNextBufferAndUnlinkg(Ljava/util/concurrent/atomic/AtomicReferenceArray;I)Ljava/util/concurrent/atomic/AtomicReferenceArray; nextIndex nextOffset nextBuffer(Ljava/util/concurrent/atomic/AtomicReferenceArray;I)Ljava/util/concurrent/atomic/AtomicReferenceArray;poll()Ljava/lang/Object; isNextBufferZ()TT;RuntimeInvisibleAnnotations#Lio/reactivex/annotations/Nullable; newBufferPollH(Ljava/util/concurrent/atomic/AtomicReferenceArray;JI)Ljava/lang/Object; offsetInNewnM(Ljava/util/concurrent/atomic/AtomicReferenceArray;JI)TT;peek newBufferPeekclear()Vsize()IbeforecurrentProducerIndexafterisEmpty()ZadjustLookAheadSteplvProducerIndex()JlvConsumerIndexlpProducerIndexlpConsumerIndexsoProducerIndex(J)VvsoConsumerIndexcalcWrappedOffset(JI)IcalcDirectOffset(I)I soElementH(Ljava/util/concurrent/atomic/AtomicReferenceArray;ILjava/lang/Object;)V\(Ljava/util/concurrent/atomic/AtomicReferenceArray;ILjava/lang/Object;)V lvElementG(Ljava/util/concurrent/atomic/AtomicReferenceArray;I)Ljava/lang/Object;q(Ljava/util/concurrent/atomic/AtomicReferenceArray;I)Ljava/lang/Object;'(Ljava/lang/Object;Ljava/lang/Object;)Zfirstsecondpmpi (TT;TT;)Z^Ljava/lang/Object;Lio/reactivex/internal/fuseable/SimplePlainQueue; SourceFileSpscLinkedArrayQueue.java G&java/util/concurrent/atomic/AtomicLong 89 D9  0java/util/concurrent/atomic/AtomicReferenceArray GH >? =7 H C? B7 ;< java/lang/NullPointerExceptionNull is not a valid element G ab :7 de kl EF pq }~ ~ vw 67 jctools.spsc.max.lookahead.step java/lang/Object0io/reactivex/internal/queue/SpscLinkedArrayQueue/io/reactivex/internal/fuseable/SimplePlainQueuejava/lang/Mathmax(II)Iio/reactivex/internal/util/Pow2roundToPowerOfTwo(Ljava/lang/String;)VlengthmingetlazySet(ILjava/lang/Object;)V(I)Ljava/lang/Object;java/lang/Integer getInteger((Ljava/lang/String;I)Ljava/lang/Integer;intValue1435 6789:7;<=7>?@AB7C?@AD9EFGHI]**Y*Y=d>Y` :* * * * **d* J:0",1$2(344:5?6D7J8O9W:\;K4]LM]N7$9O7(5P74)Q?R]LS4)QATUI + Y* M*B* 6!6!* *,+!*6!a6,*!a e*,+!,! a *,+!*,!+JFDEHIJK'L0M:O@QLRVSaTkU{VXYKR@SV7LGW7LMXFQ?zY<tP7'lZ7R LSX[QA\*]^_0@`abI+,*! aJ_`aK4LMQ?XFY<Z7R LSQAX[@cdeI B+6Y : * * a e *+ +* aJ& fghi!j*k1l:nAoKRBLMBf?Bg<BZ7BXFBP<<h71i? R*BLSBfABX[1iA @jklIw++d,J rsK LMm?n?R LSmAnA@opqI>+:+JwxyzK4LMm?r7s7 t?R LSmA tA@uvwI7c* L*A*6 6+:6+* a **+`! "J6   /:AHKPaKHcLM^Q? YY<SP7KZ7 CXF/4xyRcLS^QA\,]_^@@z{|}~I,*+ 6+:+* a J ")K>,LM,t?,Y<,P7 7FR ,LS,tA[\ )^@wI<* L*A*6 6+:**+`! #J"  (9K><LM7Q? 2Y<,P7$Z7 XFR<LS7QA\9]_^@z~I*+ 6+J K4LMt?Y<P7 7RLStA@I\*$*%J K LMR LS\I!*&@B*'7*&@! eJ K*< <!LM<R !LS\IY*'*&JK LMR LS\@HIX*l()J  KLMh7R LSID**JK LMR LSID**JK LMR LSID**JK LMR LSID**JK LMR LSIS *+J K LM <R  LSIS *+J K LM <R  LS I<~JKY<P7 I,JK Y7 I[*,,J K Q?Z7XFR QA@ IL*-JKQ?Z7R QA@TI * N*'7* 6.a6-)6-`,-+*.aO-6Y : * 6 `, +*- -*.aJN    (1:ANT_enx!K\ TFh7_;i? LMFFQ? <7~7R4_;iA LS[[QA\N]^^_K@I5012(3YJ !.@