in storehaus-http/src/main/scala/com/twitter/storehaus/http/HttpStore.scala [70:90]
override def put(kv: (String, Option[Buf])): Future[Unit] = {
val request = kv match {
case (k, Some(buf)) =>
val req = Request(Method.Put, k)
req.content = buf
req.contentLength = buf.length
req
case (k, None) =>
val req = Request(Method.Delete, k)
req.contentLength = 0
req
}
client(request).map{ response =>
response.status match {
case Status.Ok => ()
case Status.Created => ()
case Status.NoContent => ()
case _ => throw HttpException(response)
}
}
}