Создать исходный код из метода опроса в Akka

У меня есть метод, который получает элементы из разных источников с помощью метода опроса, если есть запрос на новый элемент. Как я могу создать источник из этого метода, чтобы он запрашивал только новый элемент только из метода опроса?


scala akka akka-stream
person Rajeev    schedule 07.04.2018    source источник
comment
Вы можете ознакомиться с doc.akka. io / docs / akka / 2.5 / stream /   -  person cchantep    schedule 07.04.2018

Ответы (1)


arrow_upward
2
arrow_downward

Интеграция с API опроса объясняется в сообщении блога akka.io: Написание Akka Коннекторы потоков для существующих API в части «API на основе опроса».

По сути, вы захотите расширить TimerGraphStageLogic и делать такие вещи, как:

private void schedulePoll() {
  scheduleOnce("poll", pollInterval);
}

@Override
public void onTimer(Object timerKey) {
  if (!isClosed(out)) {
    doPoll();
    if (!buffer.isEmpty()) {
      pushHead();
    } else {
      schedulePoll();
    }
  }
}

чтобы запланировать опрос.

В качестве альтернативы вы можете придерживаться реализации всех обратных вызовов в пределах _ 3_.

Полную реализацию такого этапа можно найти на здесь (реализация на Java).

person Konrad 'ktoso' Malawski    schedule 09.04.2018