Акка, как подключить источник, поток и приемник - PullRequest
Новая
       37

Акка, как подключить источник, поток и приемник

0 голосов
/ 27 октября 2019

Я создал источник, поток и приемник

Источник является целочисленным источником

Поток передает целое число в строку

, а приемник записывает вfile

Но я не знаю, как соединить их все вместе, чтобы получить работающий график 

 public static void main(String[] args) {
        ActorSystem system = ActorSystem.create();
        Materializer materializer = ActorMaterializer.create(system);
        Source<Integer, NotUsed> source = Source.range(0, 100);
        Flow<Integer, ByteString, NotUsed> flow = Flow.fromFunction((i) -> {
            return ByteString.fromString(i.toString());
        });
        Sink<ByteString, CompletionStage<IOResult>> sink = FileIO.toPath(Paths.get("love.txt"));
    }

1 Ответ

0 голосов
/ 28 октября 2019

Я сфокусировал вашу формулировку "бегущий график". Пожалуйста, посмотрите на https://doc.akka.io/docs/akka/current/stream/stream-graphs.html#constructing-graphs с осторожностью, принимая java для вашего языка программирования слева для правильных примеров кода. На этой странице приведен пример кода графического кода, который должен помочь вам соединить ваши потоковые элементы вместе.

...