Commit f7a0b1ba authored by Filipe de Lima Brito's avatar Filipe de Lima Brito

Update RealmSpotlightRoomRepository.java

parent 189c7958
...@@ -17,8 +17,7 @@ import chat.rocket.persistence.realm.models.ddp.RealmRoom; ...@@ -17,8 +17,7 @@ import chat.rocket.persistence.realm.models.ddp.RealmRoom;
import chat.rocket.persistence.realm.models.ddp.RealmSpotlightRoom; import chat.rocket.persistence.realm.models.ddp.RealmSpotlightRoom;
import hu.akarnokd.rxjava.interop.RxJavaInterop; import hu.akarnokd.rxjava.interop.RxJavaInterop;
public class RealmSpotlightRoomRepository extends RealmRepository public class RealmSpotlightRoomRepository extends RealmRepository implements SpotlightRoomRepository {
implements SpotlightRoomRepository {
private final String hostname; private final String hostname;
...@@ -27,8 +26,7 @@ public class RealmSpotlightRoomRepository extends RealmRepository ...@@ -27,8 +26,7 @@ public class RealmSpotlightRoomRepository extends RealmRepository
} }
@Override @Override
public Flowable<List<SpotlightRoom>> getSuggestionsFor(String name, SortDirection direction, public Flowable<List<SpotlightRoom>> getSuggestionsFor(String name, SortDirection direction, int limit) {
int limit) {
return Flowable.defer(() -> Flowable.using( return Flowable.defer(() -> Flowable.using(
() -> new Pair<>(RealmStore.getRealm(hostname), Looper.myLooper()), () -> new Pair<>(RealmStore.getRealm(hostname), Looper.myLooper()),
pair -> RxJavaInterop.toV2Flowable( pair -> RxJavaInterop.toV2Flowable(
...@@ -39,8 +37,7 @@ public class RealmSpotlightRoomRepository extends RealmRepository ...@@ -39,8 +37,7 @@ public class RealmSpotlightRoomRepository extends RealmRepository
.or() .or()
.equalTo(RealmSpotlightRoom.Columns.TYPE, RealmRoom.TYPE_PRIVATE) .equalTo(RealmSpotlightRoom.Columns.TYPE, RealmRoom.TYPE_PRIVATE)
.endGroup() .endGroup()
.findAllSorted(RealmSpotlightRoom.Columns.NAME, .findAllSorted(RealmSpotlightRoom.Columns.NAME, direction.equals(SortDirection.ASC) ? Sort.ASCENDING : Sort.DESCENDING)
direction.equals(SortDirection.ASC) ? Sort.ASCENDING : Sort.DESCENDING)
.asObservable()), .asObservable()),
pair -> close(pair.first, pair.second) pair -> close(pair.first, pair.second)
) )
...@@ -60,4 +57,4 @@ public class RealmSpotlightRoomRepository extends RealmRepository ...@@ -60,4 +57,4 @@ public class RealmSpotlightRoomRepository extends RealmRepository
return spotlightRooms; return spotlightRooms;
} }
} }
\ No newline at end of file
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment