akka-stream

5ısı

1cevap

Kaynak kuyruğunu araya getirmeden arayanı nasıl kullanabilirim?

Yeni Akka akışlarını kullanmaya çalışıyorum ve kaynak kuyruğunu nasıl kullanabileceğimi ve kodumda materyalleştirmeden nasıl arama yapabileceğimi merak ediyorum. Zaman uyumsuz çağrıların sayısını yapa

6ısı

1cevap

akka-stream - Akış/Grafikte farklı bir akışın son öğesi nasıl işlenir

Bir JSON nesnesi akışını tek bir JSON nesnesi dizisine dönüştürecek olan bir Akka Streams Flow kullanmaya çalışıyorum . Concat'u, "[" önce ve "]" sonra eklemek için Zip öğelerinin arasına virgül eklem

1ısı

1cevap

Scala Akka Streams Birleştirme Filtresi Ve Harita

Aşağıdaki Scala kodunu optimize etmenin herhangi bir yolu olup olmadığını merak ediyorum çünkü çok verimli görünmüyor. Temel olarak, Tweet olmayan herhangi bir nesneyi akıştan kaldırmak ve Any yerine

13ısı

1cevap

Bir Akka Streams SourceQueue, PlayFramework ile nasıl kullanılır?

Öğeleri dinamik olarak bir Akka Stream kaynağına göndermek için bir SourceQueue kullanmak isterim. Yürütme denetleyicisinin, chuncked yöntemini kullanarak bir sonucu akışlandırabilmesi için bir Kaynağ

1ısı

1cevap

Grup akış elemanları

bir ağırlık fonksiyonu val weightFunction: Element => Int göz önüne alındığında, bir val myFlow: Flow[Element] = ... //some flow.. hayal Her elemanı bir val transformedFlow: Flow[List[Element]]

6ısı

1cevap

Küme düğümlerinde çalışan Akka Streams

Akka Streams'in ölçekleme bölümünü anlamaya çalışıyorum, burada çeşitli yanıtlar gördüm, ancak yine de bu işlevin nasıl gerçekleştirildiğini anlayamıyorum. Aktarımdan anladığımdan, akışla etkileşime g

8ısı

1cevap

Bir Akka Streams lavabosunun birden fazla dosya yazmasından nasıl birleştirilir?

Akka akışları tabanlı akışları Play 2.5 uygulamasına entegre etmeye çalışıyorum. Buradaki fikir, bir fotoğrafta akış yapabilmeniz, daha sonra ham dosya, küçük boyutlu bir sürüm ve filigranlı bir sürüm

13ısı

1cevap

Akka HTTP kullanarak dosya yükleme

Akka HTTP kullanarak uygulamamda dosya yükleme işlevselliği uygulamaya çalışıyorum. akka-stream sürüm 2.4.4 kullanıyorum. İşte Bu kod iyi çalışıyor ve verilen yoluna dosya yüklerken ( akka-doc değişti

3ısı

1cevap

Akka Streams'de Sink.fold() işlem serileştiriliyor mu?

Akka akışlarına başladım; Bir web servisinden veri okuyan ve ardından S3'te devam eden bir akış oluşturmaya çalışıyorum. Sink.fold yöntemini kullanarak (kalıcı elemanlar hakkında bilgi toplamak için)

0ısı

2cevap

Akka

'da hem Strict hem de Streamed WebSocket İletilerini Tüketmek Akka HTTP kullanarak bir web yuvası hizmeti oluşturmayı deniyorum. Birden çok kareye ulaşan Aktarılan iletilerin yanı sıra, toplam olarak