let pagingAction: PagingAction<String, SampleResponse> = PagingAction<String, SampleResponse>(
    itemsPerPage: 10,
    removeDuplicates: { $0.id },
    request: { (input, page) in
        return api.getItems(for: input, page: page)
    }
)

...

pagingAction.allItems.subscribe(onNext: { items in
    print(items)
})

pagingAction.errors.subscribe(onError: { error in
    print(error)
})

...

pagingAction.reload("Some Input")
pagingAction.next("Some Input")