Интеграция Актера на основе ack с akka-stream

У меня есть Актер, который был разработан для работы с подтверждением akka-io, так что он будет ждать подтверждения при отправке сообщений вверх по течению (в сеть). Этот актор является интерфейсом к асинхронному приложению в бэкенде.

Я хотел бы иметь слой-оболочку, который позволяет мне преобразовать этого Актера в akka-streams Flow[Incoming, Outgoing, ???], чтобы его можно было интегрировать с более новыми библиотеками, которые ожидают такую ​​подпись.

(Входящие сообщения из восходящего потока редки, поэтому мы не слишком заботимся о обратном давлении там, но было бы неплохо иметь его.)

sealed trait Incoming //... with implementations
sealed trait Outgoing //... with implementations
object Ack

// `upstream` is an akka-io connection actor that will send Ack
// when it writes an Outgoing message to the socket
class SimpleActor(upstream: Actor) extends Actor {
  def receive = {
    case in: Incoming if sender() == upstream =>
       // does some work in response to upstream
    case other =>
       // does some work in response to downstream
       // including sending messages to upstream and
       // `becoming` a stashing state waiting for Ack
       // to `unbecome`, then sending Ack downstream
       // (which will respect the backpressure).
  }
}

У меня есть достоверные данные из списка рассылки akka-user, что в akka-streams нет кода, который интегрирует акторов с потоками, и для того, чтобы подключить Actor к Stream и сохранить обратное давление на основе Ack, нужно было бы реализовать PushPullStage .

Похоже, нам действительно понадобятся два PushPullStage здесь... один для upstream => SimpleActor и один для SimpleActor => upstream.

Мои вопросы:

1. Существуют ли какие-либо библиотеки, которые предлагают подобную интеграцию между актерами и потоками?
2. Есть ли более простой способ сделать это, чем реализация двунаправленного PushPullStage с нуля?
3. Существует ли какая-либо существующая тестовая среда, которая позволила бы провести стресс-тестирование такой реализации?