akka-stream

2熱

1答えて

ソース[ByteString、Future [IOResult]]をリスト[String]に変換してください

ファイルを読み取ろうとしています。このファイルを1行ずつリストに読み込む必要があります。 val res: stream.scaladsl.Source[ByteString, Future[IOResult]] = Ftp.fromPath(Paths.get(uri), ftpSettings) どのようにして、res値をList [String]に変換できますか？

1熱

2答えて

URLからファイルを取得するためのAkka-Alpakka Ftpライブラリのサポートはありますか？

私はFtpクライアントのためにhttps://github.com/akka/alpakka/tree/master/ftp/srcこのライブラリを使用しています。私はパスとしてファイルのURLを持っています。しかし、私はコードの実装から見ると、関数内のjava.nio.file.Pathのみをサポートしています。 val ftpSettings = FtpSettings(host, port,

1熱

1答えて

Akkaストリーム：永続性キューまたはイベントソースの使用

Akkaストリームアプリケーションでは、アプリケーションがクラッシュしたりノードがダウンすると、機内メッセージを失う危険があります。私たちがメッセージを失わないように、またアプリケーションが戻ったときに再生されるようにするためにできることは何ですか？私のアプリケーションでは、mapAsynsはIOコールとマイナーなCPUバインドタスクを実行します。純粋なAkkaアプリケーションでは、永続的な

1熱

1答えて

アッカ-HTTP

私は外部のAPIを呼び出していると私はOKとは異なるステータスコードの場合には、ユーザーに「そのまま」の結果を返したい失敗した場合、発信応答で応答：方法 val connectionFlow: Flow[HttpRequest, HttpResponse, Future[Http.OutgoingConnection]] = Http().outgoingConnection("akka

1熱

2答えて

ソースからすべてのバイトを読み取るシンクを作成するにはどうすればよいですか？

私は私の要件 def func(data : Source[ByteString,Any]) { ... } ごとにこのソースを取るScalaの方法を持っている私がやりたいすべてが、今のところ、このソースからのバイトのすべてを読み、それらをファイルに書き込むことです。私は、すべての値に対して計算をフォールドするような、もっと複雑なことをする多くの例を読んできました。私は何かをよりシンプルなもの

0熱

1答えて

収集シンクは、ソースなどの値をマテリアライズド

良い方法以下の方法で実装することがある（すなわちMaterializer制約を除去すること。）： import akka.NotUsed import akka.stream.Materializer import akka.stream.scaladsl.{Keep, Sink, Source} def assemble[A, B, C](source: Source[A, NotUse

2熱

1答えて

Akkaストリームとtcpサーバとして単一の接続を許可する

私はAkkaストリームを使用して単純なtcpサーバを構築しようとしています。 Tcp() .bind(props.host, props.port) .to(Sink.foreach(_.handleWith(handler))) .run() .onComplete { case Success(i) => logger.info(s"Serve

6熱

2答えて

akka-stream flowを再利用するエレガントな方法

私は簡単にakka-streamの流れを再利用する方法を探しています。は私が関数として再利用する予定のフローを扱うので、私は次のようにその署名を維持したいと思います：私はこのフローを使用するときに今、私のことができるようにしたいと思い Flow[Input, Output, NotUsed] 「コール'この流れを続け、さらなる処理のために結果を保管しておきます。フローを開始して[Input]を

0熱

1答えて

トリガ信号が

が akka-stream cookbook documentationこのコードスニペットは、プログラム要素の流れを誘発する方法を示しストリーム？

3熱

1答えて

複数のhttpリクエストのためのAkkaフロー

私のプロジェクトでは、私のgoogle fcmサーバーに投稿要求を送信するakkaの俳優がいます。アクタはIDのリストを取得し、リストにある数だけリクエストを作成する必要があります。私はrunForeach(println(_))のサーバーからの応答を印刷しますが、私はidsの全リストに対して1つの印刷物しか得ません。なぜこれが起こるのですか？ class FCMActor(val key: St