package Ġcom . d ju are z . rx kotlin . data . cache Ċ Ċ import Ġcom . d ju are z . rx kotlin . data . entity . Github Entity Ċ import Ġio . realm . Realm Ċ import Ġio . realm . Realm Query Ċ import Ġrx . Observable Ċ import Ġjavax . inject . Inject Ċ Ċ /** Ċ Ġ* ĠCreated Ġby Ġd ju are z Ġon Ġ 1 6 / 6 / 1 6 . Ċ Ġ*/ Ċ Ċ class ĠDB Helper Ġ@ Inject Ġconstructor () Ġ{ ĊĊĠĠĠ Ġprivate Ġval Ġrealm : ĠRealm Ġ= ĠRealm . getDefaultInstance () ĊĊĠĠĠ Ġfun Ġsave ( github : ĠGithub Entity ) Ġ{ ĊĠĠĠĠĠ Ġ/* Ġ Ġrealm . beginTransaction () ĊĠĠĠĠĠĠĠ Ġrealm . copy To Realm OrUpdate ( github ) ĊĠĠĠĠĠĠĠ Ġrealm . commit Transaction () ĊĠĠĠĠĠĠĠ Ġ*/ ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġfun Ġget ( id : ĠString ): ĠObservable < Github Entity > Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn ĠObservable . create Ġ{ Ġsubscriber Ġ-> ĊĠĠĠĠĠĠĠĠĠĠĠ Ġval Ġsaved User : ĠGithub Entity ? Ġ= ĠRealm Query . createQuery ( realm , ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠGithub Entity :: class . java ). equalTo (" name ", Ġid ) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. findFirst () ĊĠĠĠĠĠĠĠĠĠĠĠ Ġif Ġ( saved User Ġ!= Ġnull ) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġsubscriber . onNext ( saved User ) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġsubscriber . on Completed () ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} Ġelse Ġsubscriber . onError ( Throwable ()) ĊĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} Ċ Ċ } Ċ