Future[Option] in Scala for-comprehensions -


i have 2 functions return futures. i'm trying feed modified result first function other using for-yield comprehension.

this approach works:

  val schoolfuture = {     ud <- userstore.getuserdetails(user.userid)     sid = ud.right.tooption.flatmap(_.schoolid)     s <- schoolstore.getschool(sid.get) if sid.isdefined   } yield s

however i'm not happy having "if" in there, seems should able use map instead.

but when try map:

  val schoolfuture: future[option[school]] = {     ud <- userstore.getuserdetails(user.userid)     sid = ud.right.tooption.flatmap(_.schoolid)     s <- sid.map(schoolstore.getschool(_))   } yield s

i compile error:

[error]  found   : option[scala.concurrent.future[option[school]]] [error]  required: scala.concurrent.future[option[school]] [error]         s <- sid.map(schoolstore.getschool(_))

i've played around few variations, haven't found attractive works. can suggest nicer comprehension and/or explain what's wrong 2nd example?

here minimal complete runnable example scala 2.10:

import concurrent.{future, promise}  case class user(userid: int) case class userdetails(userid: int, schoolid: option[int]) case class school(schoolid: int, name: string)  trait error  class userstore {   def getuserdetails(userid: int): future[either[error, userdetails]] = promise.successful(right(userdetails(1, some(1)))).future }  class schoolstore {   def getschool(schoolid: int): future[option[school]] = promise.successful(option(school(1, "big school"))).future }  object demo {   import concurrent.executioncontext.implicits.global    val userstore = new userstore   val schoolstore = new schoolstore    val user = user(1)    val schoolfuture: future[option[school]] = {     ud <- userstore.getuserdetails(user.userid)     sid = ud.right.tooption.flatmap(_.schoolid)     s <- sid.map(schoolstore.getschool(_))   } yield s }

this answer similar question promise[option[a]] might help. substitute future promise.

i'm inferring following types getuserdetails , getschool question:

getuserdetails: userid => future[either[??, userdetails]] getschool: schoolid => future[option[school]]

since ignore failure value either, transforming option instead, have 2 values of type a => future[option[b]].

once you've got monad instance future (there may 1 in scalaz, or write own in answer linked), applying optiont transformer problem this:

for {   ud  <- optiont(getuserdetails(user.userid) map (_.right.tooption))   sid <- optiont(future.successful(ud.schoolid))   s   <- optiont(getschool(sid)) } yield s

note that, keep types compatible, ud.schoolid wrapped in (already completed) future.

the result of for-comprehension have type optiont[future, schoolid]. can extract value of type future[option[schoolid]] transformer's run method.


Comments

Post a Comment

Popular posts from this blog

php - failed to open stream: HTTP request failed! HTTP/1.0 400 Bad Request -

this code i'm using find latitude , longitude of place: function coords($address){ echo $url="http://maps.googleapis.com/maps/api/geocode/json?address=".$address; $json = file_get_contents(urlencode($url)); $data = json_decode($json, true); print_r($data['results'][0]['geometry']['location']['lat']); print_r($data['results'][0]['geometry']['location']['lng']); } however returns warning: failed open stream: http request failed! http/1.0 400 bad request if use above code in simple procedure works fine not in function. note: have tried curl_init()... method produced same result? instead of encoding whole url encode address part. following code work fine $add='jamshoro phase 2'; $url="http://maps.googleapis.com/maps/api/geocode/json?address=".urlencode($add); $json = file_get_contents($url); $data = json_decode($json, true); print_r($data['r...
Read more

command line - Use qwinsta in PowerShell ISE -

i trying use qwinsta , rwinsta powershell code. when try run error "the term 'qwinsta' not recognized name of cmdlet, function, script file, or operable program." need able remotely on several machines without having add .dll's or modules other machines. tried terminal services powershell module, need able put on remote machines , not able that. within powershell ise how run qwinsta? not looking parse information gather it. following code have tried (which had found on site also): function get-tssessions { param( $computername = "localhost" ) qwinsta /server:$computername | #parse output foreach-object { $_.trim() -replace "\s+","," } | #convert objects convertfrom-csv } get-tssessions -computername "localhost" | ft -autosize best have running powershell ise (x86). when run command qwinsta there same error you. of course assuming have 64-bit os. th...
Read more

java - Incorrect order of records in M-M relationship in hibernate -

Image
i have 4 records in bridge table in mysql database. using @manytomany in hibernate, accurate order of employees incorrect incorrect of projects. following required material figure out doing mistake. this source. @entity @table(name="project") public class projectbean { @id @generatedvalue @column(name="project_id") private int projectid; @column(name="title") private string projecttitle; @manytomany(mappedby="projects") private collection<employeebean> employees; public projectbean() { employees = new arraylist<employeebean>(); } //getters & setters } @entity @table(name="employee") public class employeebean { @id @generatedvalue @column(name="employee_id") private int employee_id; @column(name="first_name") private string ...
Read more