shit

RealmUserGateway.kt

    override fun currentUserCollection(page: Int?, limit: Int?): Single<PaginationResponse<UserCurrentEntity>> =
        Single.create<PaginationResponse<UserCurrentEntity>> { emitter ->
            realm.executeTransaction { realm ->
                realm.where(RealmUserCurrentEntity::class.java)
                    .findAll()
                    .run {
                        val items = this.drop(page * limit)
                            .take(limit)
                            .let { realm.copyFromRealm(it) }
                            .map { it.toDomain() }

                        val totalItems = this.count()

                        val extraPage = if (totalItems % limit > 0) 1 else 0

                        return@run PaginationResponse(
                            totalItems = totalItems,
                            itemsPerPage = limit,
                            countOfPages = totalItems / limit + extraPage,
                            items = items
                        )
                    }
                    .let(emitter::onSuccess)
            }
        }.subscribeOn(scheduler)