package Ġco . nim ble hq . sms for warder . common . transformers Ċ Ċ import Ġio . reactivex . Observable Ċ import Ġio . reactivex . Observable Source Ċ import Ġio . reactivex . Observable Transformer Ċ import Ġio . reactivex . functions . Bi Function Ċ Ċ class ĠTake When Transformer < S , Ġin ĠT > Ġconstructor ( private Ġval Ġobservable : ĠObservable < in ĠT >) Ġ: ĠObservable Transformer < S , ĠS > Ġ{ ĊĊĠĠĠ Ġoverride Ġfun Ġapply ( upstream : ĠObservable < S >): ĠObservable Source < S > Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn Ġobservable . with Latest From ( upstream , ĠBi Function Ġ{ Ġ_, Ġt 2 Ġ-> Ġt 2 Ġ}) ĊĠĠĠ Ġ} Ċ } Ċ