package Ġjp . co . sor am its u . fe ar less _ utils . integration Ċ Ċ import Ġjp . co . sor am its u . fe ar less _ utils . ws rpc . request . runtime . storage . Storage Subscription Multip lexer Ċ import Ġjp . co . sor am its u . fe ar less _ utils . ws rpc . request . runtime . storage . subscribe Using Ċ import Ġjp . co . sor am its u . fe ar less _ utils . ws rpc . subscribe Ċ import Ġkotlinx . coroutines . flow . first Ċ import Ġkotlinx . coroutines . run Blocking Ċ import Ġorg . junit . Ignore Ċ import Ġorg . junit . Test Ċ Ċ @ Ignore (" Manual Ġrun Ġonly ") Ċ class ĠCompound Subscription Test Ġ: ĠBase IntegrationTest () Ġ{ ĊĊĠĠĠ Ġ@ Test ĊĠĠĠ Ġfun Ġ` should Ġsubscribe Ġmultiple Ġkeys `() Ġ= Ġrun Blocking Ġ{ ĊĠĠĠĠĠĠĠ Ġval Ġbuilder Ġ= ĠStorage Subscription Multip lexer . Builder () ĊĊĠĠĠĠĠĠĠ Ġval Ġone Flow Ġ= Ġbuilder . subscribe (" 0 x 5 f 3 e 4 9 0 7 f 7 1 6 ac 8 9 b 6 3 4 7 d 1 5 ece ced ca 4 8 7 df 4 6 4 e 4 4 a 5 3 4 ba 6 b 0 cbb 3 2 4 0 7 b 5 8 7 ") ĊĠĠĠĠĠĠĠ Ġval Ġtwo Flow Ġ= Ġbuilder . subscribe (" 0 x 0 1 ") ĊĊĠĠĠĠĠĠĠ Ġsocket Service . subscribe Using ( builder . build ()) ĊĊĠĠĠĠĠĠĠ Ġprintln ( one Flow . first (). value ) ĊĠĠĠĠĠĠĠ Ġprintln ( two Flow . first (). value ) ĊĠĠĠ Ġ} Ċ }