Trying out Streams in lagom

AkkaStream.java

  @Override
    public ServiceCall<Source<String, ?>, Source<String, NotUsed>> test() {
        Logger.info("Got something streamed");
        return inputStream -> {
            inputStream.runForeach(input -> {
                Logger.info("Got {} streamed", input);
                ref.ask(new MyCommand());
            }, materializer);
            return CompletableFuture.completedFuture(pubSubRef.subscriber());
        };