akka-stream

8ısı

2cevap

Tüm HttpResponse gövdesini Akka-Streams HTTP ile bir dize olarak alın

Yeni akka.http kitaplığını nasıl kullanacağımı anlamaya çalışıyorum. Bir sunucuya bir http isteği göndermek ve Source[String,?] üretmek için tüm yanıt gövdesini tek bir String olarak okumak istiyorum.

7ısı

1cevap

Akka-http 3,0 Ben kaygan 3.0 kullanarak ve aşağıdaki gibi ben dinlenme katman için akka-http kullanıyorum</p> <pre><code>def getAsStream = db.stream[Entity](tblquery.result) </code></pre> <p>olarak databasepublisher nesne var am

Databasepublisher, val route = path("stream"){ get { complete { // how to stream from here } } } Nasıl Kaygan kullanarak yapabilirsiniz akışı Bu veritabanını istemci nesnesine dönüştürm

5ısı

1cevap

Akka akımları sürekli nasıl gerçekleşebilir?

AWS Java SDK kullanarak AWS SQS kuyruğundan sorgulamak için Scala'da Akka Streams kullanıyorum. , Ne zaman val system = ActorSystem("system") val sqsSource = Source.actorPublisher[Message](SQSSubscri

5ısı

2cevap

Bir aktör çağrısının sonucuyla nasıl yanıt verilir?

Routing DSL kullanarak Akka-HTTP Java API'yi kullanıyoruz. Bir HttpRequest'e yanıt vermek için Yönlendirme işlevinin nasıl kullanılacağı açık değildir; Bir Untyped Akka Aktör kullanarak. Örneğin, bir

5ısı

1cevap

Akka akışına kaynak olarak çoklu aktörler nasıl eklenir?

Ben oluşturmak ve kaynakları olarak 2 aktörler, daha sonra bir birleştirme kavşak ile (Java DSL aylarında) akka akışı akışını çalıştırmak ve çalışıyorum sonra 1 lavabo: Source<Integer, ActorRef> src1