akka-stream

5Ciepło

2Odpowiedz

Akka HTTP Websocket, jak zidentyfikować połączenia wewnątrz aktora

Pracuję nad prostą grą multiplayer w scala, którą chciałbym udostępnić poprzez strony internetowe dla klientów JS. Oto moja klasa WebsocketServer class WebsocketServer(actorRef: ActorRef, protocol: Pr

8Ciepło

2Odpowiedz

Jak korzystać z HTTP Akka do generowania treści przez strumień wyjściowy

Jestem całkiem początkującym dla Akka Streams i Akka HTTP. Chciałbym wygenerować prosty serwer HTTP, który może wygenerować plik zip z zawartości folderu i wysłać go do klienta. Plik org.zeroturnaroun

5Ciepło

1Odpowiedz

Co oznaczają parametry typu dla źródła <Out,Mat>?

Próbuję zrozumieć typ źródła dla strumieni Akka, określony here. Niestety, dokumentacja i przykłady, które znalazłem, nie wyjaśniają, co właściwie oznaczają poszczególne parametry. Zgaduję, że Out jes

6Ciepło

3Odpowiedz

Podział źródła strumienia Akka na dwa

Mam strumienie Akka Source, które chcę podzielić na dwa źródła zgodnie z predykatem. E.g. że źródło (typy uproszczony celowo) val source: Source[Either[Throwable, String], NotUsed] = ??? I dwiema me

5Ciepło

2Odpowiedz

Czy łączenie połączeń w akka-http przy użyciu wątku źródłowego implementacji jest bezpieczne?

odnosząc się do poniższego realizacji wymienionych w: http://doc.akka.io/docs/akka-http/10.0.5/scala/http/client-side/host-level.html val poolClientFlow = Http().cachedHostConnectionPool[Promise[HttpR

5Ciepło

1Odpowiedz

Komponowanie BodyParser w zagraj 2,5

Biorąc pod uwagę funkcję z tym podpisem: def parser[A](otherParser: BodyParser[A]): BodyParser[A] Jak mogę napisać funkcję w taki sposób, że ciało żądanie jest zbadane i zweryfikowane, zanim zostani

6Ciepło

1Odpowiedz

Łańcuch żądań Akka-http-client w strumieniu

Chciałbym połączyć żądanie http za pomocą akka-http-client jako Stream. Każde żądanie http w łańcuchu zależy od sukcesu/odpowiedzi poprzednich żądań i używa go do skonstruowania nowego żądania. Jeśli

6Ciepło

1Odpowiedz

Akka Strumienie podzielony przez strumień typu

mam następujący prosty przypadek hierarchię klasy: sealed trait Message case class Foo(bar: Int) extends Message case class Baz(qux: String) extends Message i mam Flow[Message, Message, NotUsed] (

5Ciepło

3Odpowiedz

Serwer proxy sieci Web korzystający z kanałów Play 2.6 i akka

Próbuję utworzyć prosty serwer proxy dla połączeń Websocket, używając strumieni Play i akka. przepływ ruchu jest tak: (Client) request -> -> request (Server) Proxy (Client) response <-

5Ciepło

1Odpowiedz

Jak radzić sobie ze źródłem, które emituje przyszłość [T]?

Powiedzmy mam trochę iterator: val nextElemIter: Iterator[Future[Int]] = Iterator.continually(...) I chcę zbudować źródło z tego iteratora: val source: Source[Future[Int], NotUsed] = Source.fro