package Ġio . wave beans . execution . pod proxy Ċ Ċ import Ġio . wave beans . execution . medium . value Ċ import Ġio . wave beans . execution . pod . Pod Key Ċ import Ġio . wave beans . lib . stream . Finite Stream Ċ import Ġjava . util . concurrent . TimeUnit Ċ Ċ class ĠAny Finite Stream Pod Proxy ( ĊĠĠĠĠĠĠĠ Ġpod Key : ĠPod Key , ĊĠĠĠĠĠĠĠ Ġfor Partition : ĠInt Ċ ) Ġ: ĠFin ite Stream < Any >, ĠStreaming Pod Proxy ( ĊĠĠĠĠĠĠĠ Ġpointed To Ġ= Ġpod Key , ĊĠĠĠĠĠĠĠ Ġfor Partition Ġ= Ġfor Partition Ċ ) Ġ{ ĊĠĠĠ Ġoverride Ġfun Ġlength ( time Unit : ĠTimeUnit ): ĠLong Ġ{ ĊĠĠĠĠĠĠĠ Ġval Ġb ush Ġ= Ġpod Discovery . b ush For ( point ed To ) ĊĠĠĠĠĠĠĠ Ġval Ġcaller Ġ= Ġb ush Caller Repository . create ( b ush , Ġpointed To ) ĊĠĠĠĠĠĠĠ Ġreturn Ġcaller . call (" length ? time Unit =${ time Unit }") ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. get ( 5 0 0 0 , ĠTimeUnit . MILLISECONDS ) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. value () ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġoverride Ġfun Ġsamples Count (): ĠLong Ġ{ ĊĠĠĠĠĠĠĠ Ġval Ġb ush Ġ= Ġpod Discovery . b ush For ( point ed To ) ĊĠĠĠĠĠĠĠ Ġval Ġcaller Ġ= Ġb ush Caller Repository . create ( b ush , Ġpointed To ) ĊĠĠĠĠĠĠĠ Ġreturn Ġcaller . call (" samples Count ") ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. get ( 5 0 0 0 , ĠTimeUnit . MILLISECONDS ) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. value () ĊĠĠĠ Ġ} Ċ }