Akka-http request handler for application/octet-stream

akkahttp_routes.scala

pathPrefix("user") {
          path("msgPackTest") {
            post {
              extractRequest {
                req =>
                  println(req.headers)
                  req.entity match {
                    case strict: HttpEntity.Strict =>
                      val resp = req.entity.dataBytes.runFold(ByteString.empty) { case (acc, b) => acc ++ b }
                        .map(x=> processMsgPackMsg(x.compact.toArray[Byte]))
                      complete {
                        resp
                      }
                    case _ =>
                      complete("Ooops, request entity is not strict!")
                  }

              }

            }
          }
        }