2$   ?                 K    C  6  BehaviorDisposable InnerClasses EMPTY_ARRAY[Ljava/lang/Object;value-Ljava/util/concurrent/atomic/AtomicReference; SignatureALjava/util/concurrent/atomic/AtomicReference; subscribersoLjava/util/concurrent/atomic/AtomicReference<[Lio/reactivex/subjects/BehaviorSubject$BehaviorDisposable;>;EMPTY;[Lio/reactivex/subjects/BehaviorSubject$BehaviorDisposable; TERMINATEDlock*Ljava/util/concurrent/locks/ReadWriteLock;readLock!Ljava/util/concurrent/locks/Lock; writeLock terminalEventDLjava/util/concurrent/atomic/AtomicReference;indexJcreate)()Lio/reactivex/subjects/BehaviorSubject;CodeLineNumberTableD()Lio/reactivex/subjects/BehaviorSubject;RuntimeVisibleAnnotations+Lio/reactivex/annotations/CheckReturnValue;RuntimeInvisibleAnnotations"Lio/reactivex/annotations/NonNull; createDefault;(Ljava/lang/Object;)Lio/reactivex/subjects/BehaviorSubject;LocalVariableTable defaultValueLjava/lang/Object;LocalVariableTypeTableTT;G(TT;)Lio/reactivex/subjects/BehaviorSubject;()Vthis'Lio/reactivex/subjects/BehaviorSubject;,Lio/reactivex/subjects/BehaviorSubject;(Ljava/lang/Object;)V(TT;)VsubscribeActual(Lio/reactivex/Observer;)VexLjava/lang/Throwable;observerLio/reactivex/Observer;bs:Lio/reactivex/subjects/BehaviorSubject$BehaviorDisposable;Lio/reactivex/Observer<-TT;>;?Lio/reactivex/subjects/BehaviorSubject$BehaviorDisposable; StackMapTable (Lio/reactivex/Observer<-TT;>;)V onSubscribe((Lio/reactivex/disposables/Disposable;)Vd%Lio/reactivex/disposables/Disposable;onNexttoonError(Ljava/lang/Throwable;)V onComplete hasObservers()ZsubscriberCount()I getThrowable()Ljava/lang/Throwable;#Lio/reactivex/annotations/Nullable;getValue()Ljava/lang/Object;()TT; getValues()[Ljava/lang/Object;ab[TT; DeprecatedLjava/lang/Deprecated;(([Ljava/lang/Object;)[Ljava/lang/Object;arrayv ([TT;)[TT; hasComplete hasThrowablehasValueadd=(Lio/reactivex/subjects/BehaviorSubject$BehaviorDisposable;)ZlenIrs@[Lio/reactivex/subjects/BehaviorSubject$BehaviorDisposable;B(Lio/reactivex/subjects/BehaviorSubject$BehaviorDisposable;)Zremove=(Lio/reactivex/subjects/BehaviorSubject$BehaviorDisposable;)VijB(Lio/reactivex/subjects/BehaviorSubject$BehaviorDisposable;)V terminateO(Ljava/lang/Object;)[Lio/reactivex/subjects/BehaviorSubject$BehaviorDisposable; terminalValueT(Ljava/lang/Object;)[Lio/reactivex/subjects/BehaviorSubject$BehaviorDisposable; setCurrent:Lio/reactivex/subjects/Subject; SourceFileBehaviorSubject.java%io/reactivex/subjects/BehaviorSubject gh gl1java/util/concurrent/locks/ReentrantReadWriteLock MN O OP Q QP+java/util/concurrent/atomic/AtomicReference JK HE DE REdefaultValue is null l8io/reactivex/subjects/BehaviorSubject$BehaviorDisposable g |}  h java/lang/Throwable Lq h  h\onNext called with null. Null values are generally not allowed in 2.x operators and sources.  l TU   ]onError called with null. Null values are generally not allowed in 2.x operators and sources.          BC java/lang/Object    LK  ! " Mh #hio/reactivex/subjects/Subject(java/util/concurrent/locks/ReadWriteLock#()Ljava/util/concurrent/locks/Lock;,io/reactivex/internal/functions/ObjectHelperrequireNonNull8(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;lazySetA(Lio/reactivex/Observer;Lio/reactivex/subjects/BehaviorSubject;)Vio/reactivex/Observer cancelledZ emitFirstget*io/reactivex/internal/util/ExceptionHelper#io/reactivex/disposables/Disposabledispose+io/reactivex/internal/util/NotificationLitenext&(Ljava/lang/Object;)Ljava/lang/Object;emitNext(Ljava/lang/Object;J)V compareAndSet'(Ljava/lang/Object;Ljava/lang/Object;)Z"io/reactivex/plugins/RxJavaPluginserror)(Ljava/lang/Throwable;)Ljava/lang/Object;completeisError(Ljava/lang/Object;)ZgetError)(Ljava/lang/Object;)Ljava/lang/Throwable; isCompletegetClass()Ljava/lang/Class;java/lang/ClassgetComponentTypejava/lang/reflect/Array newInstance&(Ljava/lang/Class;I)Ljava/lang/Object;java/lang/System arraycopy*(Ljava/lang/Object;ILjava/lang/Object;II)V getAndSetjava/util/concurrent/locks/Lockunlock1? BCDEFGHEFIJKLKMNOPQPREFSTU VWX YYFZ[\]^ _`XE Y*Ya  bcd  beFf[\]^ghXN**Y** **  * Y * Y* YY")7BMa Nijd NikglXj**+YaijbcdikbeFmnoXRY+*M+,*,, *,,,%*N- +  +-!Y.  (/:AJQa*:pqRijRrs Htud RikRrv Htwx(yzF{|}Xh* +"Y aij~d ikxlXL+#W*+$M*,%*&N-66-2:,*'(Y&    ; E Ka*; tuLijLc5cd ; twLikLex&FmXH+)W*+*+++,M*,-N-66-2:,*'(Y& 7AGa*7 tuHijHq+cd7 twHikxz&hX<**.L*+-M,>6,2:+*'(Y "#+$5#;&a + tu<ij)cd+ tw<ikx&X[*&Y*a ijd ikx@XH *&Y.a  ijd  ikXv*L+/+0Y4568aijcd ikx]X~*L+1 +/+2YBCDFaijcd ikx F]X34L*+5M,36,YRS TUWa ijC Cd ik x 44[X X*M,,1 ,/++S+,2N++-S+ +S+78944L+-S+Y6 ghij#l%n*o/p3q9r@uRvVxa*XijXCPc*.cd XikX*.exF[XW *L+1Y }~a ijcd  ikXW *L+/Y a ijcd  ikXz *L++1+/Y a ijcd  ikx @X?*&M,:,>`:,;+S*,*Y*  (-:<a4 1K%K?ij?ud* 1?ik?wx &'FX|*&M,>66,2+ 6  :'d:,;,`dd;*,*YR '+.49:?GOYkxyaRDK nKkcO*K|ij|ud4D nO*|ik|wx( & #& yFX*:<&M,:*+%,Ya ijcKdikx&FlX{%* =*Y' a'*+* >Y $a%ij%cd %ikhX663 :YFA @