尝试使用Akka流封送jaxb对象时为空文件

Question

[我试图将jaxb对象编组为xml字符串，然后使用akka Streams将其写入文件，但是在执行创建的文件后为空。

我已经检查了封送处理方法，但是在没有流的情况下可以正常工作。请帮助我了解哪里有错误。

这是我的测试方法：

  @Test
    public void singlePojoTest() {
        ActorSystem actor = ActorSystem.create();
        Materializer materializer = ActorMaterializer.create(actor);
        //Creating and initializing of JAXB POJO
        AuditFile.Header header = new AuditFile.Header();
        initHeader(header,calendar);
        // useMarshaller - is converting object to xml String
        Flow<Object,String,NotUsed> flow = Flow.of(Object.class).map(o -> useMarshaller(o));
        Source<String,NotUsed> source = Source.single((Object)header).via(flow);
        CompletionStage<IOResult> result = source.map(string -> ByteString.fromString(string)).runWith(FileIO.toPath(Paths.get("test.txt")),materializer);
        actor.terminate();
    }

我希望在执行方法之后-将创建具有封送处理的xml的文件。

Answer 1

您在启动流后立即等待不中断流就调用actor.terminate();。

您必须“阻塞”您的测试线程，并允许异步流处理完成，然后才能终止actor系统。

在关闭actor系统之前应用以下内容。

result.toCompletableFuture().get();