PK!!OO,META-INF/lib-ipc-messagebridge.kotlin_module 5 %org.openeel.lib.ipc.messagebridge.ext MessageExtKt"*PK!!-.8oqq8org/openeel/lib/ipc/messagebridge/IpcMessageBridge.class='2org/openeel/lib/ipc/messagebridge/IpcMessageBridgejava/lang/ObjectexecuteForResponsec(Lorg/openeel/lib/ipc/messagebridge/MessageData;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;(Lorg/openeel/lib/ipc/messagebridge/MessageData;Lkotlin/coroutines/Continuation<-Lorg/openeel/lib/ipc/messagebridge/MessageData;>;)Ljava/lang/Object;$Lorg/jetbrains/annotations/Nullable;#Lorg/jetbrains/annotations/NotNull;executeForFlowO(Lorg/openeel/lib/ipc/messagebridge/MessageData;)Lkotlinx/coroutines/flow/Flow;(Lorg/openeel/lib/ipc/messagebridge/MessageData;)Lkotlinx/coroutines/flow/Flow;close()VLkotlin/Metadata;mvkxi0d1r       f20J020H¦@¢J0020H&J0 H&¨ Àd24Lorg/openeel/lib/ipc/messagebridge/IpcMessageBridge;/Lorg/openeel/lib/ipc/messagebridge/MessageData; messageDataLkotlinx/coroutines/flow/Flow;lib-ipc-messagebridgeIpcMessageBridge.kt SignatureRuntimeInvisibleAnnotations$RuntimeInvisibleParameterAnnotations SourceFileRuntimeVisibleAnnotations"#$    " # $  %!&L[IIIII[s[ sssssss ss ss PK!!`Vorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeMessengerImpl$executeForFlow$1.class=Porg/openeel/lib/ipc/messagebridge/IpcMessageBridgeMessengerImpl$executeForFlow$1Lkotlin/coroutines/jvm/internal/SuspendLambda;Lkotlin/jvm/functions/Function3;Ljava/lang/Throwable;Lkotlin/coroutines/Continuation<-Lkotlin/Unit;>;Ljava/lang/Object;>;,kotlin/coroutines/jvm/internal/SuspendLambdakotlin/jvm/functions/Function3(ILorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeMessengerImpl;Lkotlinx/coroutines/channels/Channel;Lorg/openeel/lib/ipc/messagebridge/MessageData;Lkotlin/coroutines/Continuation;)V?(ILorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeMessengerImpl;Lkotlinx/coroutines/channels/Channel;Lorg/openeel/lib/ipc/messagebridge/MessageData;Lkotlin/coroutines/Continuation<-Lorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeMessengerImpl$executeForFlow$1;>;)V $messageIdI  this$0ALorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeMessengerImpl;  $receiveChannel%Lkotlinx/coroutines/channels/Channel;   $messageData/Lorg/openeel/lib/ipc/messagebridge/MessageData;  $(ILkotlin/coroutines/Continuation;)V  thisRLorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeMessengerImpl$executeForFlow$1; $receiver $completion Lkotlin/coroutines/Continuation; invokeSuspend&(Ljava/lang/Object;)Ljava/lang/Object;.Lkotlin/coroutines/jvm/internal/DebugMetadata;f IpcMessageBridgeMessengerImpl.ktlnlisnmcPorg.openeel.lib.ipc.messagebridge.IpcMessageBridgeMessengerImpl$executeForFlow$1v)kotlin/coroutines/intrinsics/IntrinsicsKt2getCOROUTINE_SUSPENDED()Ljava/lang/Object; 45 36label 8 9kotlin/ResultKt;throwOnFailure(Ljava/lang/Object;)V => <?IpcMessageBridgeA>XapiMessageBridgeBinderImpl: executeForFlow: Flow # completedC$java/lang/invoke/StringConcatFactoryEmakeConcatWithConstants(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/invoke/CallSite; GH FIJ(I)Ljava/lang/String; GLMandroid/util/LogOd'(Ljava/lang/String;Ljava/lang/String;)I QR PS?org/openeel/lib/ipc/messagebridge/IpcMessageBridgeMessengerImplUaccess$getOutgoingMessenger$pY(Lorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeMessengerImpl;)Landroid/os/Messenger; WX VYandroid/os/Message[obtain()Landroid/os/Message; ]^ \_what a \barg1 d \e-org/openeel/lib/ipc/messagebridge/MessageDataggetArg2()I ij hkarg2 m \nandroid/os/Messengerpsend(Landroid/os/Message;)V rs qt'kotlinx/coroutines/channels/SendChannelv4kotlinx/coroutines/channels/SendChannel$DefaultImplsx close$defaultT(Lkotlinx/coroutines/channels/SendChannel;Ljava/lang/Throwable;ILjava/lang/Object;)Z z{ y| kotlin/Unit~INSTANCE Lkotlin/Unit; java/lang/IllegalStateException/call to 'resume' before 'invoke' with coroutine(Ljava/lang/String;)V  ;$i$a$-also-IpcMessageBridgeMessengerImpl$executeForFlow$1$1itLandroid/os/Message;$resultLjava/lang/Object;invokep(Lkotlinx/coroutines/flow/FlowCollector;Ljava/lang/Throwable;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;(Lkotlinx/coroutines/flow/FlowCollector<-Lorg/openeel/lib/ipc/messagebridge/MessageData;>;Ljava/lang/Throwable;Lkotlin/coroutines/Continuation<-Lkotlin/Unit;>;)Ljava/lang/Object;   #$ p1'Lkotlinx/coroutines/flow/FlowCollector;p2Ljava/lang/Throwable;p3J(Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;%kotlinx/coroutines/flow/FlowCollectorjava/lang/Throwablekotlin/coroutines/Continuation VLkotlinx/coroutines/channels/Channel;Lkotlin/Metadata;mvkxi0d16    0*0020H d2 executeForFlowO(Lorg/openeel/lib/ipc/messagebridge/MessageData;)Lkotlinx/coroutines/flow/Flow;  DefaultImpls SignatureCodeLocalVariableTable StackMapTableLineNumberTable InnerClassesEnclosingMethod SourceFileRuntimeVisibleAnnotationsBootstrapMethods08   m**,*-**>  !" #$ 7W*:t+@B*NTW*Z`M*>*:,::6cflo,u*w}WY_6 h i/k6lMmSnYocpflgkjsxt|h*M J[Y****-*"AM*+,-*ywV'n% &s'([)[*[+[,[-s#.s/0I1[I1IIII[s[ssssssKDPK!!JJZorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeMessengerImpl$executeForResponse$1.class=QTorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeMessengerImpl$executeForResponse$1/kotlin/coroutines/jvm/internal/ContinuationImplL$0Ljava/lang/Object;L$1L$2I$0I.Lkotlin/coroutines/jvm/internal/DebugMetadata;f IpcMessageBridgeMessengerImpl.ktlVnlWisn messageDatamessage completeable messageIdmexecuteForResponsec?org.openeel.lib.ipc.messagebridge.IpcMessageBridgeMessengerImplvd(Lorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeMessengerImpl;Lkotlin/coroutines/Continuation;)V(Lorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeMessengerImpl;Lkotlin/coroutines/Continuation<-Lorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeMessengerImpl$executeForResponse$1;>;)Vthis$0ALorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeMessengerImpl; #$ %#(Lkotlin/coroutines/Continuation;)V ' (thisVLorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeMessengerImpl$executeForResponse$1; $completion Lkotlin/coroutines/Continuation; invokeSuspend&(Ljava/lang/Object;)Ljava/lang/Object;$Lorg/jetbrains/annotations/Nullable;#Lorg/jetbrains/annotations/NotNull;result 2 3label 5 6kotlin/coroutines/Continuation9?org/openeel/lib/ipc/messagebridge/IpcMessageBridgeMessengerImpl;c(Lorg/openeel/lib/ipc/messagebridge/MessageData;Lkotlin/coroutines/Continuation;)Ljava/lang/Object; = <>$resultLkotlin/Metadata;mvkxi0CodeLocalVariableTable SignatureRuntimeInvisibleAnnotations$RuntimeInvisibleParameterAnnotations InnerClassesEnclosingMethod SourceFileRuntimeVisibleAnnotations0 2#$5  !H= *+&*,)I  *+ #$ ,-J"./HE*+4**787*&*:?I*+@K0L1M N<>O Py s [I[I[IIII[ssss [ssssssIAB[IICIDIEFIGPK!!xU Worg/openeel/lib/ipc/messagebridge/IpcMessageBridgeMessengerImpl$incomingHandler$1.class=Qorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeMessengerImpl$incomingHandler$1android/os/HandlerW(Lorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeMessengerImpl;Landroid/os/Looper;)Vthis$0ALorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeMessengerImpl;   (Landroid/os/Looper;)V   thisSLorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeMessengerImpl$incomingHandler$1; $receiver$super_call_param$1Landroid/os/Looper; handleMessage(Landroid/os/Message;)Vmsgkotlin/jvm/internal/IntrinsicscheckNotNullParameter'(Ljava/lang/Object;Ljava/lang/String;)V  android/os/MessagewhatI  !arg1 # $?org/openeel/lib/ipc/messagebridge/IpcMessageBridgeMessengerImpl&access$getPendingMessages$pk(Lorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeMessengerImpl;)Ljava/util/concurrent/ConcurrentHashMap; () '*java/lang/Integer,valueOf(I)Ljava/lang/Integer; ./ -0&java/util/concurrent/ConcurrentHashMap2get&(Ljava/lang/Object;)Ljava/lang/Object; 45 36&kotlinx/coroutines/CompletableDeferred8IpcMessageBridge:0XapiMessageBridgeBinderImpl: receive repsonse #<$java/lang/invoke/StringConcatFactory>makeConcatWithConstants(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/invoke/CallSite; @A ?BC(I)Ljava/lang/String; @EFandroid/util/LogHd'(Ljava/lang/String;Ljava/lang/String;)I JK ILremove N5 3O-org/openeel/lib/ipc/messagebridge/MessageDataQ  RScomplete(Ljava/lang/Object;)Z UV 9W>XapiMessageBridgeBinderImpl: WARN: No pending message for id YFw \K I]access$getActiveFlowChannels$p _) '`#kotlinx/coroutines/channels/Channelb9XapiMessageBridgeBinderImpl: receive flow emission for #dFtrySend-JP2dKIU g5 ch)kotlinx/coroutines/channels/ChannelResultjbox-impl?(Ljava/lang/Object;)Lkotlinx/coroutines/channels/ChannelResult; lm kn6XapiMessageBridgeBinderImpl: WARN: No channel for id pF  s messageReply/Lorg/openeel/lib/ipc/messagebridge/MessageData;replyToRequestId completeable(Lkotlinx/coroutines/CompletableDeferred;receiveChannel%Lkotlinx/coroutines/channels/Channel;Landroid/os/Message;Lkotlin/Metadata;mvkxi0d1>    * 20J020H¨d2Landroid/os/Handler;lib-ipc-messagebridge(Landroid/os/Messenger;)V  IpcMessageBridgeMessengerImpl.ktCodeLineNumberTableLocalVariableTable StackMapTable InnerClassesEnclosingMethod SourceFileRuntimeVisibleAnnotationsBootstrapMethods1I *+ *,     ++"^+%=* +179N-4;GMW* +1PWRY+T:-XWj;[^W[+"N+%=* a17cN-$;fMW-RY+TioW;r^W*+t[9Cc^ !"#&$*&,'2%6)E*O+[-j1r2w346759;@CHOuvSw &AxywCw 1z{| '@}~[IIIII[s[ssssss|sD=DZDeDqPK!!h(Landroid/os/Messenger;)V#Lorg/jetbrains/annotations/NotNull;outgoingMessenger kotlin/jvm/internal/Intrinsics checkNotNullParameter'(Ljava/lang/Object;Ljava/lang/String;)V  ()V  Landroid/os/Messenger;  )java/util/concurrent/atomic/AtomicInteger(I)V  requestIdAtomic+Ljava/util/concurrent/atomic/AtomicInteger;  &java/util/concurrent/ConcurrentHashMap! "pendingMessages(Ljava/util/concurrent/ConcurrentHashMap; $% &activeFlowChannels (% )android/os/Looper+ getMainLooper()Landroid/os/Looper; -. ,/Qorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeMessengerImpl$incomingHandler$11W(Lorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeMessengerImpl;Landroid/os/Looper;)V 3 24android/os/Handler6incomingHandlerLandroid/os/Handler; 89 :android/os/Messenger<(Landroid/os/Handler;)V > =?incomingMessenger A BthisALorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeMessengerImpl;getIncomingHandler()Landroid/os/Handler;executeForResponsec(Lorg/openeel/lib/ipc/messagebridge/MessageData;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;(Lorg/openeel/lib/ipc/messagebridge/MessageData;Lkotlin/coroutines/Continuation<-Lorg/openeel/lib/ipc/messagebridge/MessageData;>;)Ljava/lang/Object;$Lorg/jetbrains/annotations/Nullable;Torg/openeel/lib/ipc/messagebridge/IpcMessageBridgeMessengerImpl$executeForResponse$1LlabelI NO MPd(Lorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeMessengerImpl;Lkotlin/coroutines/Continuation;)V S MTresultLjava/lang/Object; VW MX)kotlin/coroutines/intrinsics/IntrinsicsKtZgetCOROUTINE_SUSPENDED()Ljava/lang/Object; \] [^kotlin/ResultKt`throwOnFailure(Ljava/lang/Object;)V bc adandroid/os/Messagefobtain()Landroid/os/Message; hi gj checkNotNull lc m2org/openeel/lib/ipc/messagebridge/ext/MessageExtKtosetFromMessageDataF(Landroid/os/Message;Lorg/openeel/lib/ipc/messagebridge/MessageData;)V qr psreplyTo u gvgetAndIncrement()I xy zarg1 |O g}(kotlinx/coroutines/CompletableDeferredKtCompletableDeferred$defaultU(Lkotlinx/coroutines/Job;ILjava/lang/Object;)Lkotlinx/coroutines/CompletableDeferred;  java/util/Map%kotlin/coroutines/jvm/internal/BoxingboxInt(I)Ljava/lang/Integer; put8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; IpcMessageBridge8XapiMessageBridgeBinderImpl: executeForResponse: send #$java/lang/invoke/StringConcatFactorymakeConcatWithConstants(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/invoke/CallSite; (I)Ljava/lang/String; android/util/Logd'(Ljava/lang/String;Ljava/lang/String;)I send(Landroid/os/Message;)V =)kotlin/coroutines/jvm/internal/SpillingKtnullOutSpilledVariable&(Ljava/lang/Object;)Ljava/lang/Object; L$0 W ML$1 W ML$2 W MI$0 O M&kotlinx/coroutines/CompletableDeferredawait4(Lkotlin/coroutines/Continuation;)Ljava/lang/Object; -org/openeel/lib/ipc/messagebridge/MessageDataDXapiMessageBridgeBinderImpl: executeForResponse: receive response #java/lang/IllegalStateException/call to 'resume' before 'invoke' with coroutine(Ljava/lang/String;)V  J$i$a$-also-IpcMessageBridgeMessengerImpl$executeForResponse$completeable$1it(Lkotlinx/coroutines/CompletableDeferred;messageLandroid/os/Message; messageId completeableresponse/Lorg/openeel/lib/ipc/messagebridge/MessageData; messageData $completion Lkotlin/coroutines/Continuation; $continuation$resultkotlin/coroutines/ContinuationexecuteForFlowO(Lorg/openeel/lib/ipc/messagebridge/MessageData;)Lkotlinx/coroutines/flow/Flow;(Lorg/openeel/lib/ipc/messagebridge/MessageData;)Lkotlinx/coroutines/flow/Flow;%kotlinx/coroutines/channels/ChannelKtChannel$default(ILkotlinx/coroutines/channels/BufferOverflow;Lkotlin/jvm/functions/Function1;ILjava/lang/Object;)Lkotlinx/coroutines/channels/Channel; java/lang/IntegervalueOf 4XapiMessageBridgeBinderImpl: executeForFlow: send #*kotlinx/coroutines/channels/ReceiveChannelkotlinx/coroutines/flow/FlowKt receiveAsFlowL(Lkotlinx/coroutines/channels/ReceiveChannel;)Lkotlinx/coroutines/flow/Flow; Porg/openeel/lib/ipc/messagebridge/IpcMessageBridgeMessengerImpl$executeForFlow$1(ILorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeMessengerImpl;Lkotlinx/coroutines/channels/Channel;Lorg/openeel/lib/ipc/messagebridge/MessageData;Lkotlin/coroutines/Continuation;)V  kotlin/jvm/functions/Function3 onCompletion^(Lkotlinx/coroutines/flow/Flow;Lkotlin/jvm/functions/Function3;)Lkotlinx/coroutines/flow/Flow; receiveChannel%Lkotlinx/coroutines/channels/Channel;closeaccess$getOutgoingMessenger$pY(Lorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeMessengerImpl;)Landroid/os/Messenger;$thisaccess$getPendingMessages$pk(Lorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeMessengerImpl;)Ljava/util/concurrent/ConcurrentHashMap;access$getActiveFlowChannels$pLjava/util/concurrent/ConcurrentHashMap;>;Ljava/util/concurrent/ConcurrentHashMap;>;Lkotlin/Metadata;mvkxi0d1>D               20B0¢J0 20 H–@¢J0 020 HJ0HR0X‚¢ R0X‚¢ R 0  0 0 0 X‚¢ R  0  0 00 X‚¢ R0¢ R0X‚¢ ¨d24Lorg/openeel/lib/ipc/messagebridge/IpcMessageBridge;Lkotlinx/coroutines/flow/Flow;lib-ipc-messagebridge IpcMessageBridgeMessengerImpl.ktRuntimeInvisibleAnnotations SignatureCodeLineNumberTableLocalVariableTable$RuntimeInvisibleParameterAnnotations StackMapTable InnerClasses SourceFileRuntimeVisibleAnnotationsBootstrapMethods1   $%  (%  89 A  U+ **+*Y *"Y#'*"Y#**0M2Y*,57;*=Y*;@C!" &1EFT"UDEU # FG /*;!" DE HI  B,M#,M:  QR~ YQRdQMY*,U:  Y: _:  Q ekN-n-+t-*Cw* {6-~::6*'W:W*-  + -   QY 0  6 : gN L e :WYɷ̿$' M% M) gM M!J<H]IaJjKrL{MOPQOOSTVH(W5X8H"Oa{~OP(BDEBB2 9W % .8OJK#    w+kM,n,+t,*Cw* {>,~:**WW*,Y*+!* \ ]^_#`(b4cGeSf[h"4 m#TO4CwDEw #  +!y" DE /*!" E  /*'!" E   /**!" E%2M&' [IIIII[s[sEss ssssss$s%ssss(ss8s9sFsGsAsHssIsssss(PK!!Ė[`org/openeel/lib/ipc/messagebridge/IpcMessageBridgeServiceConnectionImpl$executeForFlow$2$1.class=<Zorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeServiceConnectionImpl$executeForFlow$2$1OLjava/lang/Object;Lkotlinx/coroutines/flow/FlowCollector;java/lang/Object%kotlinx/coroutines/flow/FlowCollector*(Lkotlinx/coroutines/flow/FlowCollector;)V\(Lkotlinx/coroutines/flow/FlowCollector<-Lorg/openeel/lib/ipc/messagebridge/MessageData;>;)V $$this$flow'Lkotlinx/coroutines/flow/FlowCollector;  ()V  this\Lorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeServiceConnectionImpl$executeForFlow$2$1;emitc(Lorg/openeel/lib/ipc/messagebridge/MessageData;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;s(Lorg/openeel/lib/ipc/messagebridge/MessageData;Lkotlin/coroutines/Continuation<-Lkotlin/Unit;>;)Ljava/lang/Object;F(Ljava/lang/Object;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;  it/Lorg/openeel/lib/ipc/messagebridge/MessageData; $completion Lkotlin/coroutines/Continuation;-org/openeel/lib/ipc/messagebridge/MessageData   valueLjava/lang/Object;XLkotlinx/coroutines/flow/FlowCollector;Lkotlin/Metadata;mvkxi0Xorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeServiceConnectionImpl$executeForFlow$2. invokeSuspend&(Ljava/lang/Object;)Ljava/lang/Object; 01(IpcMessageBridgeServiceConnectionImpl.kt SignatureCodeLocalVariableTableLineNumberTable InnerClassesEnclosingMethod SourceFileRuntimeVisibleAnnotations0 4$ 52 *+*6  4 5N *+,7 L M6    4A5H *+,!7K6   "# 8/9/24:3;%&[I'I(I)*I+,I-PK!!zN\^org/openeel/lib/ipc/messagebridge/IpcMessageBridgeServiceConnectionImpl$executeForFlow$2.class=Xorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeServiceConnectionImpl$executeForFlow$2Lkotlin/coroutines/jvm/internal/SuspendLambda;Lkotlin/jvm/functions/Function2;Lkotlin/coroutines/Continuation<-Lkotlin/Unit;>;Ljava/lang/Object;>;,kotlin/coroutines/jvm/internal/SuspendLambdakotlin/jvm/functions/Function2(Ljava/lang/String;Lorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeServiceConnectionImpl;Lorg/openeel/lib/ipc/messagebridge/MessageData;Lkotlin/coroutines/Continuation;)V (Ljava/lang/String;Lorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeServiceConnectionImpl;Lorg/openeel/lib/ipc/messagebridge/MessageData;Lkotlin/coroutines/Continuation<-Lorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeServiceConnectionImpl$executeForFlow$2;>;)V $logPrefixLjava/lang/String;  this$0ILorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeServiceConnectionImpl;   $messageData/Lorg/openeel/lib/ipc/messagebridge/MessageData;  $(ILkotlin/coroutines/Continuation;)V  thisZLorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeServiceConnectionImpl$executeForFlow$2; $receiver $completion Lkotlin/coroutines/Continuation; invokeSuspend&(Ljava/lang/Object;)Ljava/lang/Object;.Lkotlin/coroutines/jvm/internal/DebugMetadata;f(IpcMessageBridgeServiceConnectionImpl.ktlKnlNisL$0n $this$flowmcXorg.openeel.lib.ipc.messagebridge.IpcMessageBridgeServiceConnectionImpl$executeForFlow$2vLjava/lang/Object; ,4 5%kotlinx/coroutines/flow/FlowCollector7)kotlin/coroutines/intrinsics/IntrinsicsKt9getCOROUTINE_SUSPENDED()Ljava/lang/Object; ;< :=labelI ?@ Akotlin/ResultKtCthrowOnFailure(Ljava/lang/Object;)V EF DGIpcMessageBridgeI queue to sendK$java/lang/invoke/StringConcatFactoryMmakeConcatWithConstants(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/invoke/CallSite; OP NQR&(Ljava/lang/String;)Ljava/lang/String; OTUandroid/util/LogWd'(Ljava/lang/String;Ljava/lang/String;)I YZ X[Gorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeServiceConnectionImpl]access$getMessengerBridgeFlow$pu(Lorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeServiceConnectionImpl;)Lkotlinx/coroutines/flow/MutableStateFlow; _` ^akotlinx/coroutines/flow/Flowckotlinx/coroutines/flow/FlowKte filterNotNull>(Lkotlinx/coroutines/flow/Flow;)Lkotlinx/coroutines/flow/Flow; gh fikotlin/coroutines/ContinuationkfirstR(Lkotlinx/coroutines/flow/Flow;Lkotlin/coroutines/Continuation;)Ljava/lang/Object; mn fo?org/openeel/lib/ipc/messagebridge/IpcMessageBridgeMessengerImplqexecuteForFlowO(Lorg/openeel/lib/ipc/messagebridge/MessageData;)Lkotlinx/coroutines/flow/Flow; st ruZorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeServiceConnectionImpl$executeForFlow$2$1w*(Lkotlinx/coroutines/flow/FlowCollector;)V y xz)kotlin/coroutines/jvm/internal/SpillingKt|nullOutSpilledVariable ~ }collect[(Lkotlinx/coroutines/flow/FlowCollector;Lkotlin/coroutines/Continuation;)Ljava/lang/Object; d kotlin/UnitINSTANCE Lkotlin/Unit; java/lang/IllegalStateException/call to 'resume' before 'invoke' with coroutine(Ljava/lang/String;)V  $result'Lkotlinx/coroutines/flow/FlowCollector;java/lang/ObjectcreateT(Ljava/lang/Object;Lkotlin/coroutines/Continuation;)Lkotlin/coroutines/Continuation;f(Ljava/lang/Object;Lkotlin/coroutines/Continuation<*>;)Lkotlin/coroutines/Continuation;  valueinvoke(Lkotlinx/coroutines/flow/FlowCollector<-Lorg/openeel/lib/ipc/messagebridge/MessageData;>;Lkotlin/coroutines/Continuation<-Lkotlin/Unit;>;)Ljava/lang/Object;   p1p28(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; Lkotlin/Metadata;mvkxi0d1%   0*00H d2 CodeLocalVariableTable Signature StackMapTableLineNumberTable InnerClassesEnclosingMethod SourceFileRuntimeVisibleAnnotationsBootstrapMethods0?@,4  ]*+*,*-*4   )*68M>N*BT+HJ*V\W*bdj*l*,6*BpY- -+H+r*vxY,{8*l*,6*BY- -+H+WY,87D1D& I0J?KbIiKKINI 4 .QY***,N-+6-l 4B*+, A? *+8,l   4 4x^u#! "s#$[I%I%&[I%I'([I)I*+[s,s,-[s.s./s0s12I3[I3II)II[s[ssssSLPK!!Eborg/openeel/lib/ipc/messagebridge/IpcMessageBridgeServiceConnectionImpl$executeForResponse$1.class=R\org/openeel/lib/ipc/messagebridge/IpcMessageBridgeServiceConnectionImpl$executeForResponse$1/kotlin/coroutines/jvm/internal/ContinuationImplL$0Ljava/lang/Object;L$1L$2.Lkotlin/coroutines/jvm/internal/DebugMetadata;f(IpcMessageBridgeServiceConnectionImpl.ktl=@nl;Aisn messageDatacurrentBridgeVal logPrefixmexecuteForResponsecGorg.openeel.lib.ipc.messagebridge.IpcMessageBridgeServiceConnectionImplvl(Lorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeServiceConnectionImpl;Lkotlin/coroutines/Continuation;)V(Lorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeServiceConnectionImpl;Lkotlin/coroutines/Continuation<-Lorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeServiceConnectionImpl$executeForResponse$1;>;)Vthis$0ILorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeServiceConnectionImpl; #$ %#(Lkotlin/coroutines/Continuation;)V ' (this^Lorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeServiceConnectionImpl$executeForResponse$1; $completion Lkotlin/coroutines/Continuation; invokeSuspend&(Ljava/lang/Object;)Ljava/lang/Object;$Lorg/jetbrains/annotations/Nullable;#Lorg/jetbrains/annotations/NotNull;result 2 3labelI 56 7kotlin/coroutines/Continuation:Gorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeServiceConnectionImpl<c(Lorg/openeel/lib/ipc/messagebridge/MessageData;Lkotlin/coroutines/Continuation;)Ljava/lang/Object; > =?$resultLkotlin/Metadata;mvkxi0CodeLocalVariableTable SignatureRuntimeInvisibleAnnotations$RuntimeInvisibleParameterAnnotations InnerClassesEnclosingMethod SourceFileRuntimeVisibleAnnotations02#$56 !I= *+&*,)J  *+ #$ ,-K"./IE*+4**898*&*;@J*+AL0M1N O=?P Q s [I II[III[ IIIIIIIII[ sssssssss[ sssssssssssIBC[IIDIEIFGIHPK!!- - [org/openeel/lib/ipc/messagebridge/IpcMessageBridgeServiceConnectionImpl$mConnection$1.class=rUorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeServiceConnectionImpl$mConnection$1java/lang/Object!android/content/ServiceConnectionL(Lorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeServiceConnectionImpl;)Vthis$0ILorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeServiceConnectionImpl;  ()V  thisWLorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeServiceConnectionImpl$mConnection$1; $receiveronServiceConnected6(Landroid/content/ComponentName;Landroid/os/IBinder;)Vnamekotlin/jvm/internal/IntrinsicscheckNotNullParameter'(Ljava/lang/Object;Ljava/lang/String;)V  serviceIpcMessageBridge;IpcMessageBridgeServiceConnectionImpl: service connected: !$java/lang/invoke/StringConcatFactory#makeConcatWithConstants(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/invoke/CallSite; %& $'(3(Landroid/content/ComponentName;)Ljava/lang/String; %*+android/util/Log-i'(Ljava/lang/String;Ljava/lang/String;)I /0 .1android/os/Messenger3(Landroid/os/IBinder;)V 5 46Gorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeServiceConnectionImpl8access$getMessengerBridgeFlow$pu(Lorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeServiceConnectionImpl;)Lkotlinx/coroutines/flow/MutableStateFlow; :; 9<?org/openeel/lib/ipc/messagebridge/IpcMessageBridgeMessengerImpl>(Landroid/os/Messenger;)V @ ?A(kotlinx/coroutines/flow/MutableStateFlowCsetValue(Ljava/lang/Object;)V EF DGaccess$setMMessenger$pb(Lorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeServiceConnectionImpl;Landroid/os/Messenger;)V IJ 9KS$i$a$-also-IpcMessageBridgeServiceConnectionImpl$mConnection$1$onServiceConnected$1IitLandroid/os/Messenger;Landroid/content/ComponentName;Landroid/os/IBinder;onServiceDisconnected"(Landroid/content/ComponentName;)V>IpcMessageBridgeServiceConnectionImpl: service disconnected: U+Lkotlin/Metadata;mvkxi0d1b     * 20J02020HJ020H¨ d2#Landroid/content/ServiceConnection;lib-ipc-messagebridge4(Landroid/content/Context;Landroid/content/Intent;)V g(IpcMessageBridgeServiceConnectionImpl.ktCodeLineNumberTableLocalVariableTable InnerClassesEnclosingMethod SourceFileRuntimeVisibleAnnotationsBootstrapMethods1 j> *+ *k!l   jN+, +,2W* 4Y,7N* :-::6=?YBH-Lk &'3(F)I'J'M+l43MN0OPNNQNRSTjb" +W2W* L* =Hk. /0!1l""Qm n9hoipIXY[IZI[I\]I^_I`a[sbc[ ssdssessQssRsSsfq)")VPK!!}F&!&!Morg/openeel/lib/ipc/messagebridge/IpcMessageBridgeServiceConnectionImpl.class= Gorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeServiceConnectionImpljava/lang/Object2org/openeel/lib/ipc/messagebridge/IpcMessageBridge4(Landroid/content/Context;Landroid/content/Intent;)V#Lorg/jetbrains/annotations/NotNull;context kotlin/jvm/internal/Intrinsics checkNotNullParameter'(Ljava/lang/Object;Ljava/lang/String;)V  intent()V  Landroid/content/Context;  Landroid/content/Intent;  #kotlinx/coroutines/flow/StateFlowKtMutableStateFlow>(Ljava/lang/Object;)Lkotlinx/coroutines/flow/MutableStateFlow;  !messengerBridgeFlow*Lkotlinx/coroutines/flow/MutableStateFlow; #$ %)java/util/concurrent/atomic/AtomicBoolean'(Z)V ) (*closed+Ljava/util/concurrent/atomic/AtomicBoolean; ,- .Uorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeServiceConnectionImpl$mConnection$10L(Lorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeServiceConnectionImpl;)V 2 13 mConnectionWLorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeServiceConnectionImpl$mConnection$1; 56 7!android/content/ServiceConnection9android/content/Context; bindService?(Landroid/content/Intent;Landroid/content/ServiceConnection;I)Z => <?thisILorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeServiceConnectionImpl;executeForResponsec(Lorg/openeel/lib/ipc/messagebridge/MessageData;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;(Lorg/openeel/lib/ipc/messagebridge/MessageData;Lkotlin/coroutines/Continuation<-Lorg/openeel/lib/ipc/messagebridge/MessageData;>;)Ljava/lang/Object;$Lorg/jetbrains/annotations/Nullable;\org/openeel/lib/ipc/messagebridge/IpcMessageBridgeServiceConnectionImpl$executeForResponse$1GlabelI IJ HKl(Lorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeServiceConnectionImpl;Lkotlin/coroutines/Continuation;)V N HOresultLjava/lang/Object; QR HS)kotlin/coroutines/intrinsics/IntrinsicsKtUgetCOROUTINE_SUSPENDED()Ljava/lang/Object; WX VYkotlin/ResultKt[throwOnFailure(Ljava/lang/Object;)V ]^ \_(kotlinx/coroutines/flow/MutableStateFlowagetValue cX bd?org/openeel/lib/ipc/messagebridge/IpcMessageBridgeMessengerImplfandroid/content/Intenth getPackage()Ljava/lang/String; jk ilCIpcMessageBridgeServiceConnectionImpl: executeForResponse server= n$java/lang/invoke/StringConcatFactorypmakeConcatWithConstants(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/invoke/CallSite; rs qtu&(Ljava/lang/String;)Ljava/lang/String; rwxIpcMessageBridgez  send direct|xandroid/util/Logd'(Ljava/lang/String;Ljava/lang/String;)I L$0 R H)kotlin/coroutines/jvm/internal/SpillingKtnullOutSpilledVariable&(Ljava/lang/Object;)Ljava/lang/Object; L$1 R HL$2 R H CD gjava/lang/String-org/openeel/lib/ipc/messagebridge/MessageData queue to sendxkotlinx/coroutines/flow/Flowkotlinx/coroutines/flow/FlowKt filterNotNull>(Lkotlinx/coroutines/flow/Flow;)Lkotlinx/coroutines/flow/Flow; firstR(Lkotlinx/coroutines/flow/Flow;Lkotlin/coroutines/Continuation;)Ljava/lang/Object; java/lang/IllegalStateException/call to 'resume' before 'invoke' with coroutine(Ljava/lang/String;)V  E$i$a$-also-IpcMessageBridgeServiceConnectionImpl$executeForResponse$2itALorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeMessengerImpl;E$i$a$-also-IpcMessageBridgeServiceConnectionImpl$executeForResponse$3currentBridgeVal logPrefixLjava/lang/String; messageData/Lorg/openeel/lib/ipc/messagebridge/MessageData; $completion Lkotlin/coroutines/Continuation; $continuation$resultkotlin/coroutines/ContinuationexecuteForFlowO(Lorg/openeel/lib/ipc/messagebridge/MessageData;)Lkotlinx/coroutines/flow/Flow;(Lorg/openeel/lib/ipc/messagebridge/MessageData;)Lkotlinx/coroutines/flow/Flow;?IpcMessageBridgeServiceConnectionImpl: executeForFlow server= x gXorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeServiceConnectionImpl$executeForFlow$2(Ljava/lang/String;Lorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeServiceConnectionImpl;Lorg/openeel/lib/ipc/messagebridge/MessageData;Lkotlin/coroutines/Continuation;)V  kotlin/jvm/functions/Function2flow@(Lkotlin/jvm/functions/Function2;)Lkotlinx/coroutines/flow/Flow; A$i$a$-also-IpcMessageBridgeServiceConnectionImpl$executeForFlow$1close,IpcMessageBridgeServiceConnectionImpl: close getAndSet(Z)Z (5IpcMessageBridgeServiceConnectionImpl: close: cleanup mMessengerLandroid/os/Messenger; 4IpcMessageBridgeServiceConnectionImpl: close: unbind unbindService&(Landroid/content/ServiceConnection;)V <access$getMessengerBridgeFlow$pu(Lorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeServiceConnectionImpl;)Lkotlinx/coroutines/flow/MutableStateFlow;$thisaccess$setMMessenger$pb(Lorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeServiceConnectionImpl;Landroid/os/Messenger;)VmLkotlinx/coroutines/flow/MutableStateFlow;Lkotlin/Metadata;mvkxi0d11I               *20B00¢J020H–@¢J0020HJ0HR0X‚¢ R0X‚¢ R0 X‚¢ R  0 0 X‚¢ R 0X‚¢ R0X‚¢ ¨d24Lorg/openeel/lib/ipc/messagebridge/IpcMessageBridge;Lkotlinx/coroutines/flow/Flow;lib-ipc-messagebridge(IpcMessageBridgeServiceConnectionImpl.ktRuntimeInvisibleAnnotations SignatureCodeLineNumberTableLocalVariableTable$RuntimeInvisibleParameterAnnotations StackMapTable InnerClasses SourceFileRuntimeVisibleAnnotationsBootstrapMethods1   F#$ ,- 56 Q+ ,**+*,*"&*(Y+/*1Y*48***8:@W* ".!:4;5O6P QABQ Q   CD ,H#,H:  LM~ YLMdLHY*,P:  T: Z:  L}X `*&egN*my:-Yq::6{~W+  + -  LY )  : gN L ` YW*&::6{W  + -  LY )  : gN L ` g+  + -  LY )  : gN L ` Y ' H- Hh" gHFP H" gH3 H" gH@ Hn<8e9r:;=;<=;;=;=8;@>?@>@A8m@8A;8JJ$rWIAB2 9R hqWDNMEF   X+¸*&egM*mN,Y#::6{-~W+YWY-*+θҰEgQ>DE F H F.G:H;F=F=H=F=HAFFIWF>. J+E 8XABX  >{ָW*/ښ-{ܸW*{W**8:*="RSTU"V*W8X=[ >AB/*& B:*+B1H|[IIIII[s[sBss ssssssss#s$ss,s-s5s0s6sCsssDsssss vov}vvPK!!()V  this8Lorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeTags; INSTANCE #Lorg/jetbrains/annotations/NotNull;LOGTAGLjava/lang/String;IpcMessageBridgeLkotlin/Metadata;mvkxi0d1E     Æ20B ¢R0X†T¢ ¨d2lib-ipc-messagebridgeIpcMessageBridgeTags.ktRuntimeInvisibleAnnotations ConstantValueCodeLineNumberTableLocalVariableTable SourceFileRuntimeVisibleAnnotations1 $%$&/*'(   & Y )#*@[IIIII[s [s s!ssss!s"PK!! Aorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeWhatFlags.class=-;org/openeel/lib/ipc/messagebridge/IpcMessageBridgeWhatFlagsjava/lang/Object()V  this=Lorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeWhatFlags; INSTANCE #Lorg/jetbrains/annotations/NotNull; WHAT_REQUESTI WHAT_RESPONSEWHAT_FLOW_EMISSIONWHAT_FLOW_COMPLETIONLkotlin/Metadata;mvkxi0d1     Æ20B ¢R0X†T¢ R0X†T¢ R0X†T¢ R0X†T¢ ¨ d2lib-ipc-messagebridgeIpcMessageBridgeWhatFlags.ktRuntimeInvisibleAnnotations ConstantValueCodeLineNumberTableLocalVariableTable SourceFileRuntimeVisibleAnnotations1 &''''(/*)*   ( Y +%,I[IIIII [s!"[ s s#ssss#ssss$PK!!*)ȸ3org/openeel/lib/ipc/messagebridge/MessageData.class=-org/openeel/lib/ipc/messagebridge/MessageDatajava/lang/Object(Landroid/os/Bundle;III)V#Lorg/jetbrains/annotations/NotNull;datakotlin/jvm/internal/Intrinsics checkNotNullParameter'(Ljava/lang/Object;Ljava/lang/String;)V ()V  Landroid/os/Bundle;  whatI  arg1  arg2  this/Lorg/openeel/lib/ipc/messagebridge/MessageData;H(Landroid/os/Bundle;IIIILkotlin/jvm/internal/DefaultConstructorMarker;)V  #getData()Landroid/os/Bundle;getWhat()IgetArg1getArg2(Landroid/os/Message;)Vmessage,android/os/Message. %& /0 getData(...)2checkNotNullExpressionValue 4 5 / / /Landroid/os/Message; component1 component2 component3 component4copyG(Landroid/os/Bundle;III)Lorg/openeel/lib/ipc/messagebridge/MessageData; copy$default(Lorg/openeel/lib/ipc/messagebridge/MessageData;Landroid/os/Bundle;IIIILjava/lang/Object;)Lorg/openeel/lib/ipc/messagebridge/MessageData; ?@ CtoString()Ljava/lang/String;+MessageData(data=, what=, arg1=, arg2=)G$java/lang/invoke/StringConcatFactoryImakeConcatWithConstants(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/invoke/CallSite; KL JMN*(Landroid/os/Bundle;III)Ljava/lang/String; KPQhashCodeandroid/os/BundleT S( UVjava/lang/IntegerX(I)I SZ Y[resultequals(Ljava/lang/Object;)Z$Lorg/jetbrains/annotations/Nullable;areEqual'(Ljava/lang/Object;Ljava/lang/Object;)Z ab cotherLjava/lang/Object;Lkotlin/Metadata;mvkxi0d1s.           †20B+0000¢ B 0 ¢ J 0HÆJ 0HÆJ 0HÆJ 0HÆJ1020202020HÆJ020HփJ 0HցJ 0HցR0¢  R0¢ R0¢ R0¢ ¨d2lib-ipc-messagebridgeMessageData.ktRuntimeInvisibleAnnotationsCodeLineNumberTableLocalVariableTable$RuntimeInvisibleParameterAnnotations StackMapTable SourceFileRuntimeVisibleAnnotationsBootstrapMethods1vw + **+***x y4 !    z "wT~>~6*+${ x %&w/*xy  !v'(w/*xy  !)(w/*xy  !*(w/*xy  !+wa!+-*+1Y36+7+8+9$x y! !!,:z;&w#*y  !v<(w#*y  !=(w#*y  !>(w#*y  !?@wY+ Y+$y4 !vz  ABwT<~*L~*=~*>~ *6*+D{ EFw4****Ry  !vS(wY1*W<h*\`<h*\`<h*\`<y)]1 !^_wN*+++M*,d*,*,*,{  yN !Nefz`|u}gh[IiIjIklImnIop[sqr[s!ssssssssssss,s:s+s%s&s's(s)s*s;ss?s^sssesSsEssst~OHPK!!VV9org/openeel/lib/ipc/messagebridge/MessengerProvider.class=3org/openeel/lib/ipc/messagebridge/MessengerProviderjava/lang/Objectinvoke()Landroid/os/Messenger;#Lorg/jetbrains/annotations/NotNull;Lkotlin/Metadata;mvkxi0d17    æ€20J 0H¦¨Àd25Lorg/openeel/lib/ipc/messagebridge/MessengerProvider;Landroid/os/Messenger;lib-ipc-messagebridgeMessengerProvider.ktRuntimeInvisibleAnnotations SourceFileRuntimeVisibleAnnotations: [I I I II[s[sssssPK!!Y,Torg/openeel/lib/ipc/messagebridge/ServiceConnectionMessengerProvider$Companion.class=(Norg/openeel/lib/ipc/messagebridge/ServiceConnectionMessengerProvider$Companionjava/lang/Object()V  thisPLorg/openeel/lib/ipc/messagebridge/ServiceConnectionMessengerProvider$Companion;1(Lkotlin/jvm/internal/DefaultConstructorMarker;)V $constructor_marker.Lkotlin/jvm/internal/DefaultConstructorMarker;Lkotlin/Metadata;mvkxi0d1E     †20B ¢R0X†T¢ ¨d2LOGTAGlib-ipc-messagebridgeDorg/openeel/lib/ipc/messagebridge/ServiceConnectionMessengerProvider Companion%ServiceConnectionMessengerProvider.ktCodeLineNumberTableLocalVariableTable InnerClasses SourceFileRuntimeVisibleAnnotations1"/*#C$   "-* $  %  &!'@[IIIII[s[s ssssssPK!!+  Xorg/openeel/lib/ipc/messagebridge/ServiceConnectionMessengerProvider$mConnection$1.class=oRorg/openeel/lib/ipc/messagebridge/ServiceConnectionMessengerProvider$mConnection$1java/lang/Object!android/content/ServiceConnectionI(Lorg/openeel/lib/ipc/messagebridge/ServiceConnectionMessengerProvider;)Vthis$0FLorg/openeel/lib/ipc/messagebridge/ServiceConnectionMessengerProvider;  ()V  thisTLorg/openeel/lib/ipc/messagebridge/ServiceConnectionMessengerProvider$mConnection$1; $receiveronServiceConnected6(Landroid/content/ComponentName;Landroid/os/IBinder;)Vnamekotlin/jvm/internal/IntrinsicscheckNotNullParameter'(Ljava/lang/Object;Ljava/lang/String;)V  serviceHttpIpc6ServiceConnectionMessengerProvider: onServiceConnected!android/util/Log#i'(Ljava/lang/String;Ljava/lang/String;)I %& $'android/os/Messenger)(Landroid/os/IBinder;)V + *,Dorg/openeel/lib/ipc/messagebridge/ServiceConnectionMessengerProvider.access$getMessengerFuture$pu(Lorg/openeel/lib/ipc/messagebridge/ServiceConnectionMessengerProvider;)Ljava/util/concurrent/atomic/AtomicReference; 01 /2+java/util/concurrent/atomic/AtomicReference4get()Ljava/lang/Object; 67 58&java/util/concurrent/CompletableFuture:complete(Ljava/lang/Object;)Z <= ;>HServiceConnectionMessengerProvider: onServiceConnected: future completed@access$setMMessenger$p_(Lorg/openeel/lib/ipc/messagebridge/ServiceConnectionMessengerProvider;Landroid/os/Messenger;)V BC /DP$i$a$-also-ServiceConnectionMessengerProvider$mConnection$1$onServiceConnected$1IitLandroid/os/Messenger;Landroid/content/ComponentName;Landroid/os/IBinder;onServiceDisconnected"(Landroid/content/ComponentName;)V9ServiceConnectionMessengerProvider: onServiceDisconnectedN ;set(Ljava/lang/Object;)V QR 5Sp0Lkotlin/Metadata;mvkxi0d1b     * 20J02020HJ02 0H¨ d2#Landroid/content/ServiceConnection;lib-ipc-messagebridge4(Landroid/content/Context;Landroid/content/Intent;)V e%ServiceConnectionMessengerProvider.ktCodeLineNumberTableLocalVariableTable InnerClassesEnclosingMethod SourceFileRuntimeVisibleAnnotations1 h> *+ *ij   hP+, "(W* *Y,-N* :-::639;?W A(W-Ei" !"/#@$H%K"L"O&j4/FG,HIPPJPKLMhb" O(W* E* 3;YPTi)*+!,j""UJk l/fmgnLVW[IXIYIZ[I\]I^_[s`a[ ssbsscssJssKsLsUsdPK!!KJorg/openeel/lib/ipc/messagebridge/ServiceConnectionMessengerProvider.class=Dorg/openeel/lib/ipc/messagebridge/ServiceConnectionMessengerProviderjava/lang/Object3org/openeel/lib/ipc/messagebridge/MessengerProviderjava/io/Closeable4(Landroid/content/Context;Landroid/content/Intent;)V#Lorg/jetbrains/annotations/NotNull;context kotlin/jvm/internal/IntrinsicscheckNotNullParameter'(Ljava/lang/Object;Ljava/lang/String;)V  intent()V  Landroid/content/Context;  Landroid/content/Intent;  )java/util/concurrent/atomic/AtomicBoolean(Z)V ! "closed+Ljava/util/concurrent/atomic/AtomicBoolean; $% &+java/util/concurrent/atomic/AtomicReference(&java/util/concurrent/CompletableFuture* +(Ljava/lang/Object;)V - ).messengerFuture-Ljava/util/concurrent/atomic/AtomicReference; 01 2Rorg/openeel/lib/ipc/messagebridge/ServiceConnectionMessengerProvider$mConnection$14I(Lorg/openeel/lib/ipc/messagebridge/ServiceConnectionMessengerProvider;)V 6 57 mConnectionTLorg/openeel/lib/ipc/messagebridge/ServiceConnectionMessengerProvider$mConnection$1; 9: ;HttpIpc=android/content/Intent? getAction()Ljava/lang/String; AB @C2ServiceConnectionMessengerProvider: init: action=E$java/lang/invoke/StringConcatFactoryGmakeConcatWithConstants(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/invoke/CallSite; IJ HKL&(Ljava/lang/String;)Ljava/lang/String; INOandroid/util/LogQi'(Ljava/lang/String;Ljava/lang/String;)I ST RU!android/content/ServiceConnectionWandroid/content/ContextY bindService?(Landroid/content/Intent;Landroid/content/ServiceConnection;I)Z [\ Z]thisFLorg/openeel/lib/ipc/messagebridge/ServiceConnectionMessengerProvider;invoke()Landroid/os/Messenger;get()Z cd ejava/lang/IllegalStateExceptiong2ServiceConnectionMessengerProvider: already closedi(Ljava/lang/String;)V k hl()Ljava/lang/Object; cn )ojoin qn +r join(...)tcheckNotNullExpressionValue v wandroid/os/Messengeryclose getAndSet(Z)Z |} ~isDone d + unbindService&(Landroid/content/ServiceConnection;)V Z7$i$a$-takeIf-ServiceConnectionMessengerProvider$close$1Iitaccess$setMMessenger$p_(Lorg/openeel/lib/ipc/messagebridge/ServiceConnectionMessengerProvider;Landroid/os/Messenger;)V mMessengerLandroid/os/Messenger; $thisaccess$getMessengerFuture$pu(Lorg/openeel/lib/ipc/messagebridge/ServiceConnectionMessengerProvider;)Ljava/util/concurrent/atomic/AtomicReference;Norg/openeel/lib/ipc/messagebridge/ServiceConnectionMessengerProvider$Companion1(Lkotlin/jvm/internal/DefaultConstructorMarker;)V  CompanionPLorg/openeel/lib/ipc/messagebridge/ServiceConnectionMessengerProvider$Companion; $Lorg/jetbrains/annotations/Nullable;oLjava/util/concurrent/atomic/AtomicReference;>;LOGTAGLjava/lang/String;Lkotlin/Metadata;mvkxi0d1A             * 2020:B00¢J 0 H–J0HR0X‚¢ R0X‚¢ R 0 X‚¢ R 0 X‚¢ R  0 00X‚¢ R0X‚¢ ¨d25Lorg/openeel/lib/ipc/messagebridge/MessengerProvider;Ljava/io/Closeable;(Ljava/util/concurrent/CompletableFuture;lib-ipc-messagebridge%ServiceConnectionMessengerProvider.kt*Lkotlin/jvm/internal/SourceDebugExtension;valueSMAP ServiceConnectionMessengerProvider.kt Kotlin *S Kotlin *F + 1 ServiceConnectionMessengerProvider.kt org/openeel/lib/ipc/messagebridge/ServiceConnectionMessengerProvider + 2 fake.kt kotlin/jvm/internal/FakeKt *L 1#1,72:1 1#2:73 *E RuntimeInvisibleAnnotations Signature ConstantValueCodeLineNumberTableLocalVariableTable$RuntimeInvisibleParameterAnnotations StackMapTable InnerClasses SourceFileSourceDebugExtensionRuntimeVisibleAnnotationsBootstrapMethods1    $% 01 9: >  m+ ,**+*,* Y#'*)Y+Y,/3*5Y*8<>*DPVW***<X^W6 &+28D0E1W2k3l m_`m m   abf+*'f hYjm*3p+sYuxz6 7: +_` {<*'3*L+M>*3p++Y*<XW(ZZ@ZPZ> ?I?!?)?;A  <_`:*+`/*3 ` Y5SMAP ServiceConnectionMessengerProvider.kt Kotlin *S Kotlin *F + 1 ServiceConnectionMessengerProvider.kt org/openeel/lib/ipc/messagebridge/ServiceConnectionMessengerProvider + 2 fake.kt kotlin/jvm/internal/FakeKt *L 1#1,72:1 1#2:73 *E s[IIIII[s[s`sss ssss s sss$s%s0s1ss9s4s:sas{sss[sMFPK!!Vhy8org/openeel/lib/ipc/messagebridge/ext/MessageExtKt.class=I2org/openeel/lib/ipc/messagebridge/ext/MessageExtKtjava/lang/ObjectsetFromMessageDataF(Landroid/os/Message;Lorg/openeel/lib/ipc/messagebridge/MessageData;)V#Lorg/jetbrains/annotations/NotNull;kotlin/jvm/internal/Intrinsics checkNotNullParameter'(Ljava/lang/Object;Ljava/lang/String;)V  messageData-org/openeel/lib/ipc/messagebridge/MessageDatagetData()Landroid/os/Bundle;  android/os/MessagesetData(Landroid/os/Bundle;)V  getWhat()I   whatI "# $getArg1 & 'arg1 )# *getArg2 , -arg2 /# 0$this$setFromMessageDataLandroid/os/Message;/Lorg/openeel/lib/ipc/messagebridge/MessageData;Lkotlin/Metadata;mvkxi0d11    0*020¨d2lib-ipc-messagebridge MessageExt.ktCodeLineNumberTableLocalVariableTable$RuntimeInvisibleParameterAnnotations SourceFileRuntimeVisibleAnnotations1Cq-* +*+*+!%*+(+*+.1D   $ , E-23-4F GBH=56[I7I8I9:I7;I<=[s>?[ss@s3ss4sAPK!! META-INF/PK!!org/PK!! org/openeel/PK!!org/openeel/lib/PK!!org/openeel/lib/ipc/PK!!"org/openeel/lib/ipc/messagebridge/PK!!&org/openeel/lib/ipc/messagebridge/ext/PK!!OO,META-INF/lib-ipc-messagebridge.kotlin_modulePK!!-.8oqq8org/openeel/lib/ipc/messagebridge/IpcMessageBridge.classPK!!`V`org/openeel/lib/ipc/messagebridge/IpcMessageBridgeMessengerImpl$executeForFlow$1.classPK!!JJZkorg/openeel/lib/ipc/messagebridge/IpcMessageBridgeMessengerImpl$executeForResponse$1.classPK!!xU W-$org/openeel/lib/ipc/messagebridge/IpcMessageBridgeMessengerImpl$incomingHandler$1.classPK!!h