ตามเทคนิคที่อธิบายไว้ สำหรับคำถามนี้ ฉันได้เขียน ไมโครเซอร์วิสพื้นฐานเพื่อให้การสตรีม ByteStrings อย่างต่อเนื่องโดยใช้ akka-http รหัสสกาล่าที่เกี่ยวข้องคือ: import akka.actor.ActorSystem import akka.stream.ActorMaterializer import...

การใช้ akka-http แบบนี้ถือเป็นการละเมิดหรือเป็นอันตรายหรือไม่? บนเซิร์ฟเวอร์ def source(consumerOffset: UUID) = readJournal.eventsByTag(“MyTag", consumerOffset).map(_.asJson) pathPrefix("stream" / Segment.map(UUID.fromString)) { offset...