pages-to-stream Create a new RxStream from pages generator. # action:: pageToken -> Promise({items, nextToken}) action = (page = null) -> getPage(page).then( (items) -> {items, nextToken} ) aRxStream = new FromPages(action).stream()