Как заблокировать существующие асинхронные веб-запросы?

Question

Я предоставил обратный вызов сторонней библиотеке, которая в разное время вызывает предоставленный метод, предоставляя мне объект, который был изменен. Затем я выполняю асинхронный веб-запрос, чтобы получить дополнительные сведения и установить их на этом объекте, ниже приведен пример аналогичного примера;

public void update(Person person) { 
    if (person.getId() == -1) { 
     mService.getPersonDetails() 
       .flatMap(..) 
       .skip(..) 
       .subscribe(personResult -> person.setId(personResult.getId())) 
    } 
} 

Обновление называется довольно много раз и должно выполнять только запрос, если объект не имеет идентификатора. Проблема в том, что по крайней мере два запроса отправляются, поскольку первый запрос еще не завершен.

Как синхронизировать этот вызов метода, чтобы только один запрос отправлялся для каждого объекта, который прошел через обратный вызов? Я только хочу блокировать запросы для этого точного объекта, поэтому, если update() предоставляет разные объекты, было бы нормально отправлять новые запросы.

Answer 1

Решение, предоставленное Adam S, выглядит хорошо, но вскоре или позже вызовет проблемы с OOM. Это связано с отдельным оператором, который должен хранить все уникальные значения.

Другим вариантом, который приходит мне на ум, является использование ConcurrentMap для хранения обработанных лиц и doOnTerminate для его очистки.

private Map<Person, Boolean> map = new ConcurrentHashMap<>(); 
    public void update(final Person person) { 
    if (person.getId() == -1) { 
     if(map.putIfAbsent(person, true)==null){ 
      mService.getPersonDetails() 
       .flatMap(..) 
       .skip(..) 
       .doOnTerminate(()->map.remove(person)) 
       .subscribe(personResult -> person.setId(personResult.getId())) 
     } 
    } 
} 

Answer 2

Ну, вы можете просто просто synchronize.

public synchronized void update(Person person) 

Answer 3

Вы можете фильтровать вклад в ваш наблюдаемый с помощью оператора distinct. Вот общее представление о том, как вы могли бы сделать это с помощью (JavaDoc) (обратите внимание, это написано по памяти, я не проверял это):

private PublishSubject<Person> personSubject; 
public void update(Person person) { 
    if (personSubject == null) { 
     personSubject = new PublishSubject(); 
     personSubject 
      .filter(person -> person.getId() == -1) 
      .distinct() 
      .flatMap(person -> mService.getPersonDetails()) 
      .skip(..) 
      .subscribe(personResult -> person.setId(personResult.getId())); 
    } 
    personSubject.onNext(person); 
} 

Вы, конечно, придется либо реализовать equals на вашем Person классе (который, как указывает Марек, приведет ко всем объектам, переданным в кеширование в памяти) или реализовать вариант distinct(Func).

Этот метод использует функцию «key selector», используемую для различения объектов. Если ваши объекты довольно тяжелые, и вы обеспокоены памятью (например, если вы на Android), это может быть лучшим путем. Что-то вроде этого:

.distinct(new Func1<Person, Integer>() { 
       @Override 
       public Integer call(Person person) { 
        return person.hashCode(); 
       } 
      })