流的HTML浏览器未来完成

当我试图流期货为的Html（在斯卡拉剧2.5.2）的想法是，它们会呈现在屏幕上时，期货完整。所以我会流一来源作为字符串这样的：流的HTML浏览器未来完成

def oneFuture = Action { request => 
    val source1: Source[String, NotUsed] = fromFuture(sc.makeServiceCall("async1")) 
    Ok.chunked(source1) 
    }

其中sc.makeServiceCall电话：

class ServiceClient @Inject() (ws: WSClient) { 

    def makeServiceCall(serviceName: String): Future[String] = { 
     ws.url(s"http://localhost:9000/mock/$serviceName").get().map(_.body) 
    } 

    }

这是参照：

class Mock @Inject() (actorSystem: ActorSystem)(implicit exec: ExecutionContext) extends Controller { 

    def mock(serviceName: String) = Action.async { request => 
     serviceName match { 
     case "async1" => respond("asy1", 1.second) 
     case "async2" => respond("asy2", 3.second) 
     } 
    } 

    private def respond(data: String, delay: FiniteDuration): Future[Result] = { 
     val promise: Promise[Result] = Promise[Result]() 
     actorSystem.scheduler.scheduleOnce(delay) { promise.success(Ok(data)) } 
     promise.future 
    } 

    }

其中1后返回asy1第二。因此，考虑到这一点，如果我想流式传输模板页，例如，我将如何在浏览器中呈现Html。 views.html.async1.async1Message("a simple string") - 那就是：

@(async1Message: String) <span style="color: red; font-size: 22px; font-weight: bold;">@async1Message</span>

来源

2017-06-07 jesus g_force Harris

你试过了什么？您是否将服务调用的结果映射到模板中，然后将其返回？这似乎更像是一个前端问题，你如何处理javascript中的响应，对吧？端点如何被调用？ – thwiegan

为什么你坚持流结果呢？您可以仅以异步方式返回整个页面，这是一个小模板。这就是说，如果这是为了学习的目的，你应该知道Source.fromFuture创建一个Akka来源与单个元素。你需要自己把它分成块。你可以这样做：

val chunkSize = 512 // 512 characters of your string 
val source = Source.fromFuture(sc.makeServiceCall("async1")) 
    .mapConcat(_.grouped(chunkSize)) 
Ok.chunked(source)

来源

2017-06-10 09:06:58

是的 - 这是在此阶段的学习目的。我得到一个'类型不匹配;找到：需要Iterator [String]：scala.collection.immutable.Iterable [？] .mapConcat（_。grouped（chunkSize））''。假设'sc.makeServiceCall（“async1”）'是一个_Future [结果] _和（正如我所说）我想返回_HTML标记_ –

流的HTML浏览器未来完成

回答

相关问题