package Ġio . pro venance . event stream . stream . flows Ċ Ċ import Ġio . pro venance . event stream . net . Net Adapter Ċ import Ġio . pro venance . event stream . stream . clients . Block Data Ċ import Ġkotlinx . coroutines . flow . Flow Ċ import Ġkotlinx . coroutines . flow . toList Ċ import Ġkotlin . time . Duration Ċ import Ġkotlin . time . Duration . Companion . seconds Ċ Ċ /** Ċ Ġ* ĠCreate Ġa Ġpolling Ġ[ Flow ] Ġof Ġ[ Block Data ] Ġfrom Ġa Ġnode Ġthat Ġlooks Ġ" live ". Ċ Ġ* Ċ Ġ* ĠAvoid s Ġall Ġthe Ġn ons ense Ġof Ġwebsocket s Ġwhile Ġach ie ving Ġthe Ġsame Ġend Ġresult . Ċ Ġ* Ċ Ġ* Ġ@ param Ġnet Adapter ĠThe Ġ[ Net Adapter ] Ġto Ġuse Ġto Ġconnect Ġto Ġthe Ġnode . Ċ Ġ* Ġ@ param Ġfrom ĠThe Ġheight Ġto Ġstart Ġthe Ġflow Ġof Ġ[ Block Data ] Ġat . Ċ Ġ*/ Ċ fun Ġpolling Block Data Flow ( net Adapter : ĠNet Adapter , Ġpoll Interval : ĠDuration Ġ= Ġ 1 0 . seconds , Ġfrom : ĠLong ? Ġ= Ġnull ): ĠFlow < Block Data > Ġ= ĊĠĠĠ Ġpolling Data Flow ( ĊĠĠĠĠĠĠĠ Ġ{ Ġnet Adapter . rpc Adapter . getCurrent Height () !! Ġ}, ĊĠĠĠĠĠĠĠ Ġpoll Interval , ĊĠĠĠĠĠĠĠ Ġfrom , ĊĠĠĠĠĠĠĠ Ġ{ Ġhistorical Block Data Flow ( net Adapter , Ġit . first (), Ġit . last ()). toList () Ġ} ĊĠĠĠ Ġ) Ċ