package Ġsample . search . data Ċ Ċ import Ġsample . rx . Rx Schedulers Ċ import Ġsample . search . data . database . Black listed Term Dao Ċ import Ġsample . search . data . database . Black listed Term Entity Ċ import Ġsample . search . domain . Black list Repository Ċ import Ġio . reactivex . Comp letable Ċ import Ġio . reactivex . Single Ċ import Ġjavax . inject . Inject Ċ Ċ /** Ċ Ġ* ĠImplementation Ġof Ġ[ Black list Repository ] Ġthat Ġmaintains Ġblack listed Ġsearch Ġterms . Ċ Ġ*/ Ċ class ĠBlack list Repository Impl Ġ@ Inject Ġconstructor ( ĊĠĠĠ Ġprivate Ġval Ġdao : ĠBlack listed Term Dao , ĊĠĠĠ Ġprivate Ġval Ġs chedulers : ĠRx Schedulers Ċ ) Ġ: ĠBlack list Repository Ġ{ ĊĊĠĠĠ Ġoverride Ġfun Ġadd ( search Term : ĠString ): ĠComp letable Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn Ġdao . insert ( Black listed Term Entity ( term Ġ= Ġsearch Term )) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. subscribe On ( schedul ers . database ) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġoverride Ġfun Ġis Black listed ( search Term : ĠString ): ĠSingle < Boolean > Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn Ġdao . findBy ( search Term ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. map Ġ{ Ġtrue Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. onError Return Ġ{ Ġfalse Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. subscribe On ( schedul ers . database ) ĊĠĠĠ Ġ} Ċ }