             .merge()
             .bindTo(fullloading)
             .addDisposableTo(disposeBag)
-                
+
         Observable
             .combineLatest(elements.asObservable(), response) { elements, response in
                 return response.hasPreviousPage ? elements + response.elements : response.elements

            .bindTo(refreshTrigger)
            .addDisposableTo(queryDisposeBag)
    }
    
    private func bindPaginationRequest(paginationRequest: PaginationRequest<Element, Filter>, nextPage: String?) {
        disposeBag = DisposeBag()
        self.paginationRequest = paginationRequest

            .filter { !$0 }
            .take(1)
            .map { _ in paginationRequest }

        let nextPageRequest = loadNextPageTrigger
            .take(1)
            .flatMap { nextPage.map { Observable.of(paginationRequest.routeWithPage($0)) } ?? Observable.empty() }

        let request = Observable
            .of(refreshRequest, nextPageRequest)
            .merge()
            .take(1)
            .shareReplay(1)

        let response = request
            .flatMap { $0.rx_collection() }
            .doOnNetworkError { [weak self] error throws in
                guard let mySelf = self else { return }
                Observable.just(error).bindTo(mySelf.networkErrorTrigger).addDisposableTo(mySelf.disposeBag)
            }
            .shareReplay(1)

        Observable
            .of(
                request.map { (true, $0.page) },
