akka-stream

10ısı

1cevap

Akka Deresi Üzerinden Via/ViaMat/to/toMat

Birisi, bu 4 yöntem arasındaki farkın ne olduğunu net bir şekilde açıklayabilir mi? Her birini kullanmak ne zaman daha uygun? Ayrıca genel olarak bu yöntem grubunun adı nedir? Aynı işi yapan daha fazl

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] =

5ısı

1cevap

Akka-http'da sorgu parametreleri nasıl okunur?

Akka-http kitaplıklarını marshal ve unmarshal sınıfının taleplerini işlerken biliyorum.Ancak, GET isteğinin istek parametrelerini okumam gerekiyor. parameter() yöntemini denedim ve ParamDefAux türünü

6ısı

1cevap

Bir Akka akışının içinde bir Geleceğe ait geri tepme yaratın

Genel olarak Akka akışları ve akışları için yeniyim, bu yüzden kavramsal bir düzeyde bir şeyi yanlış anlamış olabilirim, ancak gelecekteki bir çözüme dönüşene kadar geri tepmeyi yaratabileceğim herhan

5ısı

1cevap

AkKA Streams `groupBy` SubFlow tamamlamada kapasite değişiyor mu? <code>n</code> bazı maksimum kapasiteli bir dere akışı tanımı <code>groupBy</code> kullanırken

: Söylemek neden alt akışa yatarsan source.groupBy(Int.MaxValue, _.key).to(Sink.actorRef) , bir Aktör lavabo ve kasıtlı kısmi akımlar bazı iletide sonlanmasına sebep, groupBy kapasitesini serbest bı

7ısı

1cevap

İki Akış nasıl yan yana oluşturulur?

Aşağıdakileri yapmak için bir Akka akışları birleştiricisi var mı (yoksa bu etkiyle ilgili bir şey)? (Şimdilik and diyelim.) (flow1: Flow[I, O, Mat]).and[O2](flow2: Flow[I, O2, Mat]): Flow[I, (O, O2),

6ısı

3cevap

Akka Streams kullanarak bir CSV dosyalarını okuma

Bir csv dosyası okuyorum. Bunu yapmak için Akka Streams kullanıyorum, böylece her satırda gerçekleştirilecek eylemlerin bir grafiğini oluşturabilirim. Aşağıdaki oyuncak örneğim var ve çalışıyor. def m

8ısı

2cevap

Akka HTTP, bir çıkış akışı aracılığıyla içerik üretmek için nasıl kullanılır?

Akka Streams ve Akka HTTP için oldukça yeni biriyim. Klasörün içeriğinden bir zip dosyası oluşturabilen ve istemciye gönderebilen basit bir HTTP sunucusu oluşturmak istiyorum. org.zeroturnaround.zip.Z

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

5ısı

1cevap

Besteleme BodyParser Play 2.5

Bu imza ile bir işlevi göz önüne alındığında? Basitlik için, bir üstbilginin (belki de "Bazı Başlıklar") gövdeyle tam olarak eşleşen bir değere sahip olduğunu doğrulamak istediğimi varsayalım. Ben bu