Streaming objek JSON menggunakan respons chunked akka http

Apakah menggunakan akka-http seperti ini merupakan penyalahgunaan atau berbahaya?

Di server

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))
        )
      }
    }
  }
}

Kemudian di sisi klien

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. Apakah dijamin potongan yang saya kirim akan sama di sisi klien.
2. Bolehkah mendapat respons dengan jumlah potongan yang mungkin tidak ada habisnya?
3. Tipe Konten apa yang tepat untuk respons seperti ini?

UPD 2:

Akka 2.4.9 menambahkan kemampuan untuk merespons dengan aliran. Dan pada dasarnya melakukan hal yang persis sama, memberikan beberapa gula sintaksis. Lihat dokumen .