akka

5ısı

1cevap

Akka Kümesindeki bir Abonenin alım yöntemini nasıl test edebilirim?

aşağıdaki Subscriber soyut temel sınıf var: abstract class Subscriber(topics: Seq[String]) extends Actor with ActorLogging { import DistributedPubSubMediator.{ Subscribe, SubscribeAck } val

7ısı

1cevap

Flick ve Play 2.5 arasındaki Akka sürüm çakışması

Projemizde, bir kafka kuyruğundan çıkan, bir harita işlevi dönüşümü gerçekleştiren ve başka bir sıraya yazan bir Flink (1.1.3) akış işine sahibiz. Bu, akışın bir parçası olarak giden bir REST isteğini

16ısı

1cevap

OynaWithActor [String, JsValue] için Play 2.5.x eşdeğeri nedir?

Play 2.5.x'e geçmeden önce sık sık WebSocket.acceptWithActor kullandım. Artık web girişlerimi farklı giriş ve çıkışlar kullanırken açık kalmak için alamıyorum, benim durumumda, giriş String, çıktı JsV

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

Oynatmaya Geçiş! 2.5 bu hataya yol açar: NoSuchMethodError: akka.actor.LocalActorRefProvider.log() Lakka/event/LoggingAdapter

Oyunumu güncelliyorum! java.lang.NoSuchMethodError: akka.actor.LocalActorRefProvider.log()Lakka/event/LoggingAdapter; Akka hakkında build.sbt bölümü değiştirip (akkaVersion 2.4.14 ile) Aşağıdaki gib

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 http derleme hatası

Akka çerçevesinde yeni biriyim ve şimdi bu çerçeveyle basit web servisini kurmaya çalışıyorum. import akka.actor.ActorSystem import akka.http.scaladsl.Http import akka.http.scaladsl.server.Directive