Spray-client Rest

Spray-client Rest

import spray.json.DefaultJsonProtocol
import spray.client.pipelining._
import spray.http._
import scala.concurrent._
import akka.actor.{ActorSystem}
import scala.concurrent.ExecutionContext.Implicits.global
import scala.util._


case class User(id: Option[Int], username: Option[String])

object Tasks extends DefaultJsonProtocol{
  implicit val orderConfirmationFormat = jsonFormat2(User)
  implicit val system = ActorSystem()

  def getRequest(): Unit = {
    val pipeline: HttpRequest => Future[HttpResponse] = sendReceive

    val response: Future[HttpResponse] = pipeline(Get("http://www.baidu.com"))
    response.onComplete {
      case Failure(t) =>
        println(s"error $t")

      case Success(r) =>
        println(s"success ${r.status}")
        println(r.entity.asString)
    }
  }

    def postRequest()={
      import spray.httpx.SprayJsonSupport._
      val pipeline: HttpRequest => Future[User] =   sendReceive ~> unmarshal[User]
      val response: Future[User] = pipeline { Post("http://localhost:8088/users", User(Option(100),"jiang"))}
        response.onComplete{
          case Failure(t) =>
            println(s"error $t")
          case Success(r) =>
            println(s"success ${r}")
            println(r)
        }

      }
  
}