flow.scala

for {
  product <- productRepo.getProduct(id)
  metadata <- getMetadata(product.id)
} yield metadata


flow {
  val product = productRepo.getProduct(id)()
	getMetadata(product.id)()
}

///////////////////

flow {
  val sourceResponse = WS.url(url).get()()
  if (sourceResponse.status != Status.OK) 
  	throw new ResourceNotFoundException(url)
  postToService(sourceResponse)()
}

for {
	sourceResponse <- WS.url(url).get()
	response <- 
		if sourceResponse.status == Status.OK 
			postToService(sourceResponse)
		else 
			future(throw new ResourceNotFoundException(url))
} yield response

for(sourceResponse <- WS.url(url).get())
	response <- {
		if (sourceResponse.status != Status.OK) 
		  throw new ResourceNotFoundException(url)
	    postToService(sourceResponse)
    }
} yield response


val sourceResponseF = WS.url(url).get()
sourceResponseF flatMap { sourceResponse => 
	if (sourceResponse.status == Status.OK) 
		postToService(sourceResponse)
	else 
		future(throw new ResourceNotFoundException(url))
}

val sourceResponseF = WS.url(url).get()
sourceResponseF flatMap { sourceResponse => 
	if (sourceResponse.status != Status.OK) 
		throw new ResourceNotFoundException(url)
	postToService(sourceResponse)
}


flow {
  val sourceResponse = WS.url(url).get()()
  if (sourceResponse.status == Status.OK)
    postToService(sourceResponse)()
  else
    shiftUnit(throw new ResourceNotFoundException(url))
}