java - 更新单个列表项 RXJava

Question

我基本上想将这个 for 循环转换为 Observable

private static List<Book> books

public static void replaceBook(Book book) {
    for (int i = 0; i < books.size(); i++) {
        if (books.get(i).getId().equals(book.getId())) {
            books.set(i, book);
        }
    }
}  

这是我到目前为止所拥有的，但它不起作用。我以为 map 运算符(operator)会更新过滤后的项目，但我似乎遗漏了一些东西。

Observable.from(books).filter(new Func1<Book, Boolean>() {
        @Override
        public Boolean call(Book b) {
            return b.getId().equals(book.getId());
        }
    }).map(new Func1<Book, Book>() {
        @Override
        public Book call(Book b) {
            return book;
        }
    }).subscribe();

更新

根据鲍里斯和塔索斯的回答，我得到了以下似乎有效的答案

  Observable.from(books)
            .map(b -> b.getId().equals(book.getId()) ? book : b)
            .toList()
            .subscribe(s -> books = s);

Answer 1

Observable
  .from(books)
  .map(new Func1<Book, Book>() {
        @Override
        public Book call(Book b) {
            if (book.getId().equals(b.getId()))
                return book;
            return b;
        }
  })
  .toList()
  .subscribe();