Have you looked at onComplete / onSuccess directives that help processing futures?
On Sunday, July 5, 2015 at 11:12:29 PM UTC+2, Jack Daniels wrote: > > I'm using akka-http 1.0.-RC4. > > How can I extract Future[T] value in unmarshaller without blocking ? > > Details are here > http://stackoverflow.com/questions/31223016/why-akka-http-unmarshaler-returns-futuret-instead-of-t > > but in short here is what I want to do. > > I extended ScalaXmlSupport you created to support unmarshalling http > requests using Unmarshaller[NodeSeq, T] unmarshallers by adding this > > implicit def xmlUnmarshallerConverter[T](marshaller: > Unmarshaller[NodeSeq, T])(implicit mat: Materializer): > FromEntityUnmarshaller[T] = > xmlUnmarshaller(marshaller, mat) > > implicit def xmlUnmarshaller[T](implicit marshaller: > Unmarshaller[NodeSeq, T], mat: Materializer): FromEntityUnmarshaller[T] = > { > implicit val exec = mat.executionContext > defaultNodeSeqUnmarshaller.map(v => { > val future = marshaller(v)(mat.executionContext) > val result = Await.result(future, Duration(10, TimeUnit.SECONDS)) > result > }) > } > > The only problem is that prototype of Unmarshaller.apply is this > > def apply[A, B](f: ExecutionContext ⇒ A ⇒ Future[B]): Unmarshaller[A, B] > > > It requires me to returns Future which I do by creating unmarshallers of > model classes like > > implicit val articleBodyUnmarshaller = Unmarshaller[NodeSeq, ArticleBody] { > xml => > Future(ArticleBody(xml.toString())) > } > > > But I can't use it in xmlUnmarshaller : FromEntityUnmarshaller[T] because > it requires me to return concrete object which forces me to do ugly blocking > > How should I write it properly ? > -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>>> Check the FAQ: >>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
