import Ġkotlinx . coroutines .* Ċ import Ġkotlinx . coroutines . flow .* Ċ Ċ suspend Ġfun Ġperform Request ( request : ĠInt ): ĠString Ġ{ ĊĊĠĠĠ Ġ// Ġ ãģª ãģ« ãģĭ ãģĹ ãĤī ãģ® åĩ¦çĲĨ ĊĠĠĠ Ġdelay ( 1 0 0 0 ) ĊĠĠĠĠĊĠĠĠ Ġreturn Ġ" response Ġ$ request " Ċ } Ċ Ċ /* Ċ Ġ* ĠãĤ³ ãĥ« ãĥ¼ãĥ ģ ãĥ³ ï¼ļ éĿŀ åĲĮ æľŁ ãĥķ ãĥŃ ãĥ¼ ï¼ļ ä¸Ń éĸĵ ãĤª ãĥļ ãĥ¬ ãĥ¼ãĤ·ãĥ§ãĥ³ Ċ Ġ* ĠãĤ³ ãĥ¼ãĥ« ãĥī ãĤ¹ãĥĪ ãĥª ãĥ¼ãĥł ï¼ļ åıĹ ä¿¡ ãģĹãģªãģĦ ãģĭ ãģ İ ãĤĬ åĭķ ä½ľ ãģĹãģªãģĦ Ċ Ġ* Ġ å¿ħ ãģļ ãĤ³ ãĥ« ãĥ¼ãĥ ģ ãĥ³ãĤ¹ ãĤ³ ãĥ¼ãĥĹ ãģ« ãģªãĤĭ ãģŁãĤģ éĸ ī ãģĺ å¿ ĺ ãĤĮ ãģĮ ãģªãģĦ Ċ Ġ* Ċ Ġ* ĠãĤ³ ãĥ¬ ãĤ¯ ãĤ·ãĥ§ãĥ³ ãĤĦ ãĤ· ãĥ¼ãĤ ± ãĥ³ãĤ¹ ãģ® åł´åĲĪ ãģ¨ åĲĮ ãģĺ ãĤĪãģĨãģ« ãĢģ ãĥķ ãĥŃ ãĥ¼ ãģ¯ æ¼Ķ ç®Ĺ åŃĲ ãĤĴä½¿çĶ¨ãģĹãģ¦ å¤ī æıĽ ãģ§ãģįãĤĭ Ċ Ġ* Ġæ ¼ Ķ ç®Ĺ åŃĲ ï¼ļ map ãĤĦ filter ãģªãģ© Ċ Ġ*/ Ċ fun Ġmain () Ġ= Ġrun Blocking < Unit > Ġ{ ĊĠĠĠĠĊĠĠĠ Ġ// Ġä¸Ń éĸĵ ãĤª ãĥļ ãĥ¬ ãĥ¼ãĤ·ãĥ§ãĥ³ ĊĠĠĠ Ġprintln (" --- Intermediate Ġflow Ġoperators --- ") ĊĊĠĠĠ Ġ// Ġ å¤ī æıĽ ãĥ¡ ãĤ½ãĥĥãĥī ãĤĴ ä»ĭ ãģĹãģ¦ ãĥķ ãĥŃ ãĥ¼ å®Łè¡Į ĊĠĠĠ Ġ( 1 .. 3 ). as Flow () ĠĊĠĠĠĠĠĠĠ Ġ. map Ġ{ Ġrequest Ġ-> Ġperform Request ( request ) Ġ} ĊĠĠĠĠĠĠĠ Ġ. collect Ġ{ Ġresponse Ġ-> Ġprintln ( response ) Ġ} Ċ } Ċ Ċ // Ġ åĩºåĬĽ ï¼ļ Ċ // Ġ--- Intermediate Ġflow Ġoperators --- Ċ // Ġresponse Ġ 1 Ċ // Ġresponse Ġ 2 Ċ // Ġresponse Ġ 3