@ file : Suppress (" Package Directory Mismatch ") Ċ // ĠThis Ġfile Ġwas Ġautomatically Ġgenerated Ġfrom ĠREADME . md Ġby ĠK nit Ġtool . ĠDo Ġnot Ġedit . Ċ package Ġio . github . cf ras er . con nek ted . e 2 e . test . example 0 5 Ċ Ċ import Ġio . github . cf ras er . con nek ted . Fixed Interval Schedule Ċ import Ġio . github . cf ras er . con nek ted . Con nek ted Ċ import Ġio . github . cf ras er . con nek ted . e 2 e . test . con ne kt . transport Ċ import Ġkotlinx . coroutines . flow . flow Ċ import Ġorg . apache . commons . lang 3 . Random StringUtils Ċ import Ġjava . time . Duration Ċ Ċ fun Ġmain () Ġ{ ĊĠ ĠCon nek ted ( transport ) Ġ{ ĊĠĠĠ Ġadd Sender Ġ{ ĊĠĠĠĠĠ Ġname Ġ= Ġ" random - strings - sender " ĊĠĠĠĠĠ Ġsend To Ġ= Ġ" random - strings " ĊĠĠĠĠĠ Ġschedule Ġ= ĠFixed Interval Schedule ( Duration . of Seconds ( 3 0 )) ĊĠĠĠĠĠ Ġsend Ġ{ ĊĠĠĠĠĠĠĠ Ġflow < String > Ġ{ ĊĠĠĠĠĠĠĠĠĠ Ġrepeat ( 5 ) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġval Ġrandom String Ġ= ĠRandom StringUtils . random Alphabet ic ( 5 ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġlogger . info Ġ{ Ġ" sending Ġ$ random String " Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠ Ġemit ( random String ) ĊĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠ Ġ} ĊĠĠĠĠĠ Ġserialize ( String :: toByteArray ) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġadd Receiver Ġ{ ĊĠĠĠĠĠ Ġname Ġ= Ġ" reversed - random - strings - receiver " ĊĠĠĠĠĠ Ġreceive From Ġ= Ġ" reversed - random - strings " ĊĠĠĠĠĠ Ġon Message Ġ{ Ġmessage Ġ-> Ġlogger . info Ġ{ Ġ" received Ġ$ message " Ġ} Ġ} ĊĠĠĠĠĠ Ġdeserialize Ġ{ Ġbytes Ġ-> ĠString ( bytes ) Ġ} ĊĠĠĠ Ġ} ĊĠ Ġ} ĊĠĠĠ Ġ. run () Ċ } Ċ