akka

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

scala akka akka-stream akka-cluster 2016-04-18

---

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

scala akka akka-stream playframework-2.5 2016-05-10

---

7ısı

2cevap

Akka Persistence Query olay akışı ve CQRS

ES-CQRS mimarimdeki okuma tarafını uygulamaya çalışıyorum. en Böyle bir kalıcı aktör var diyelim: etki devam ettiği aldığında object UserWrite { sealed trait UserEvent sealed trait State

scala akka cqrs event-sourcing akka-persistence 2016-07-07

---

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

scala file-upload akka akka-stream akka-http 2016-05-25

---

5ısı

1cevap

Akka akışı - farklı bir dağıtıcıya IO bağlı Akışı koyma

Akımım, CPU bağlı ve IO bağlı aşamaların eşit bir karışımına sahiptir (her IO aşamasını bir CPU aşaması izler). Yapmak istediğim, IO işlemlerini, akışın geri kalanından farklı bir dağıtıcıya koymak. G

akka akka-stream 2016-06-01

---

8ısı

1cevap

"max izin boyut 128.000 bayt kodlanmış sınıf skalası gerçek boyutu" akka remoting

Ben aktörler arasında ağ üzerinden mesaj alışverişi için Akka Remoting kullanmak istiyorum, ancak büyük Dize mesajı için ben aşağıdaki hata var hata: akka.remote.OversizedPayloadException: Discarding

serialization akka akka-cluster akka-remoting 2016-04-18

---

6ısı

1cevap

Scala katlama nasıl çalışır?

Aşağıdaki kodu anlamaya çalışıyorum ama yapamıyorum. Varsa, bir Etkinlik için bir çocuk oyuncunun yaratılması gerekir, aksi takdirde Etkinliğin bir çocuk oyuncağı kadar var olduğunu söyler. context.ch

scala akka scala-collections 2016-05-01

---

5ısı

1cevap

Gelecek [T] yayan kaynak nasıl ele alınır?

en Bazı yineleyici var diyelim: val nextElemIter: Iterator[Future[Int]] = Iterator.continually(...) Ve o İlerleticiden bir kaynak oluşturmak istiyorum: val source: Source[Future[Int], NotUsed] =

scala akka akka-stream 2016-09-28

---

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

scala akka akka-stream 2016-05-09

---

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

json scala akka akka-stream 2016-05-09

---