Уточнение явного буфера в akka stream - PullRequest
Новая
       12

Уточнение явного буфера в akka stream

0 голосов
/ 03 ноября 2019

при записи 

Source(1 to 1000)
  .mapAsync(1)(uniformRandomSpin)
  .buffer(16, OverflowStrategy.backpressure)
  .mapAsync(1)(uniformRandomSpin)
  .buffer(16, OverflowStrategy.backpressure)
  .runWith(Sink.ignore)

1 - применяется ли буфер к предыдущему mapAsync или к следующему?

Другими словами, помещаю ли я буфер между

mapAsync ->buffer-> mapAsync -> runWith

или фактически

Source(1 to 1000) -> buffer -> mapAsync -> buffer -> mapAsync

Насколько я понимаю, буферприменить к предыдущему этапу.

Если я выполняю A (). B (). Buffer (10), то я помещаю буфер между A и B.

2 - Затем добавляется буфер вЭтап переопределяет свой внутренний буфер, или оба «объединяются», как в применении.

3 - Наконец, внутренний и явный буфер работают точно так же? Какой смысл иметь два механизма, если они делают одно и то же?

...