package Ġuni . b rem en . condition recorder . bit al ino Ċ Ċ import Ġinfo . pl ux . pl ux api . bit al ino . BIT al ino Frame Ċ import Ġio . reactivex . Observable Ċ import Ġjava . util . concurrent . TimeUnit Ċ Ċ class ĠBIT al ino Frame San ity Check Ġ{ ĊĊĠĠĠ Ġprivate Ġval Ġmax NumberOf Zero Frames Ġ= Ġ 1 0 ĊĊĠĠĠ Ġfun Ġobserve ( frames : Observable < BIT al ino Frame >): ĠObservable < String > Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn Ġobserver Zero Frames ( frames ) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġprivate Ġfun Ġobserver Zero Frames ( frames : ĠObservable < BIT al ino Frame >): ĠObservable < String > Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn Ġframes . map Ġ{ Ġframe Ġ-> Ġframe . an alog Array . sum () Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. filter Ġ{ Ġsum Ġ-> Ġsum Ġ== Ġ 0 Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. buffer ( 1 , ĠTimeUnit . SECONDS ) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. map Ġ{ Ġbuffer Ġ-> Ġbuffer . size Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. filter Ġ{ ĠnumberOf Zero Frames Ġ-> ĠnumberOf Zero Frames Ġ> Ġmax NumberOf Zero Frames Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. map Ġ{ ĠbufferSize Ġ-> Ġ" found Ġ$ buffer Size Ġ 0 Ġframes " Ġ} ĊĠĠĠ Ġ} Ċ Ċ }