Source.fromIterator(…) обеспечил потокобезопасность итератора

#java #scala #akka-stream

#java #scala #akka-stream

Вопрос:

Должен ли Iterator передаваемый в Source.fromIterator быть потокобезопасным? Ссылка на официальные документы была бы хорошей.

Ответ №1:

Нет. Ваш график извлекает их последовательно. И даже ниже по потоку, без некоторого распараллеливания, график фактически соответствует одному действующему лицу. Вас все равно устроит любой переданный итератор, благодаря вышеописанному механизму для исходного кода.