Потоковая передача объектов JSON с использованием фрагментированного ответа akka http

Это злоупотребление или как-то опасно использовать akka-http таким образом?

На сервере

def source(consumerOffset: UUID) = 
  readJournal.eventsByTag(“MyTag", consumerOffset).map(_.asJson)

pathPrefix("stream" / Segment.map(UUID.fromString)) { offset =>
  pathEndOrSingleSlash {
    get {
      complete {
        HttpResponse(
          StatusCodes.OK,
          entity = HttpEntity(ContentTypes.`application/json`, source(offset))
        )
      }
    }
  }
}

Затем на стороне клиента

Source.single(HttpRequest("http://localhost:9000/stream"))
  .mapAsync(1) { r =>
    Http().singleRequest(r).map { res =>
      res.entity.dataBytes.map(_.parse[Event])
    }
  }
  .flatMapConcat(identity).mapAsync(processEvent)

UPD:

1. Гарантировано ли, что отправленные мной куски будут такими же на стороне клиента?
2. Можно ли получить ответ, содержащий, возможно, бесконечное количество блоков?
3. Каков правильный Content-Type для такого ответа?

UPD 2:

В Akka 2.4.9 добавлена ​​возможность отвечать потоками. И в основном делает то же самое, обеспечивая некоторый синтаксический сахар. См. документы. .