akka

7Ciepło

1Odpowiedz

Scala odwołanie do obiektu uchwycenia, jednocześnie korzystając extractory

Czy jest jakiś sposób, aby to: // I'm using akka, perhaps there's a magic variable inside receive I can use def receive = { case Message(channel, data, sender) => { // do stuff with channel

6Ciepło

1Odpowiedz

jest bezpiecznie zamknąć kontekst aktora w akka scheduler

Wiem, że nie jest bezpiecznie zamknąć nad wywołaniem metody sender lub wewnętrznym stanem aktora w Przyszłości lub harmonogramem, ale co z kontekstem aktora? co jest w ActorContext? Czy można bezpiecz

5Ciepło

2Odpowiedz

Użyj przyszłości w routingu natryskowym

Jestem nowy w programowaniu asynchronicznym. Przeczytałem ten samouczek: http://danielwestheide.com/blog/2013/01/09/the-neophytes-guide-to-scala-part-8-welcome-to-the-future.html i byłem zaskoczony, j

10Ciepło

4Odpowiedz

Jak podzielić strumień przychodzący na znak ogranicznika za pomocą strumieni Akka

Bawiłem się z eksperymentalnym interfejsem API Akka Streams i mam przypadek użycia, który chciałem zobaczyć, jak zaimplementować. Dla mojego przypadku użycia, mam StreamTcp oparty Flow, który jest pod

5Ciepło

1Odpowiedz

Jak po prostu zatrzymać aktorów dziecięcych po ponownym uruchomieniu rodzica?

Mam aktora rodziców Akka z kilkorgiem dzieci. Kiedy aktor nadrzędny zostanie zrestartowany, potrzebuję go po prostu zatrzymać swoje dzieci, zamiast zatrzymywać je i ponownie tworzyć lub ponownie uruch

7Ciepło

1Odpowiedz

Jak działa powiadomienie Akka

Nie mam żadnego doświadczenia z Akka. Chciałbym wiedzieć, jak działa komunikator Akka w ramach JVM, a także między maszynami JVM. Czy wiadomości w ramach JVM są podobne do obiektów POJO? Czy jest jaki

6Ciepło

3Odpowiedz

Akka/Java: Obsługa wielu typów wiadomości wewnątrz niestandardowego aktora?

Aby zaimplementować własnego niestandardowego aktora w Akka (powiązanie Java), rozszerz klasę podstawową UntypedActor. Wymaga to, aby zdefiniować własne onReceive(...) metody: @Override public void o

5Ciepło

2Odpowiedz

Akka błąd testowania kierownik obsługi

Mam następujący: class Supervisor(dataProvider: DatabaseClientProvider) extends Actor { val writer = context.actorOf(Props(classOf[Child], dataProvider.get)) def receive: Receive = { ca

6Ciepło

2Odpowiedz

Testowanie zdarzenia timera w Akka

Mam funkcja, która wykorzystuje scheduleOnce zaplanować zdarzenie się zdarzyć jakiś czas w przyszłości, i chcę napisać test, który sprawdza, że: zdarzenie rzeczywiście zaplanowane to było zaplanowane

5Ciepło

2Odpowiedz

Wywołanie aktora na trasie natrysku i oczekiwanie na odpowiedź aktora

Po użyciu Play! Ramy na chwilę spoglądam na Spray. Zacząłem od próbki, którą znalazłem na GitHub, teraz chcę ją zmodyfikować, ale nie jest mi łatwo zrozumieć, jak to działa. Jak mogę czekać na wiadomo