scala – 数据流的SHA256

首先,我们需要一个函数来创建一个空摘要和一个用ByteBuffer更新摘要的函数：

import java.security.MessageDigest
import java.nio.ByteBuffer

def emptySHA256Digest : MessageDigest = MessageDigest getInstance "SHA-256" 

val updateDigest : (MessageDigest,ByteBuffer) => MessageDigest = 
  (messageDigest,byteBuffer) => {
    messageDigest update byteBuffer
    messageDigest
  }

然后可以在折叠中使用这两个函数,该折叠应用于HttpResponse的实体,以使用实体中的所有ByteString值更新摘要：

import akka.http.scaladsl.model.HttpResponse

val responseBodyToDigest : HttpResponse => Future[MessageDigest] = 
  (_ : HttpResponse)
    .entity
    .dataBytes
    .map(_.asByteBuffer)
    .runFold(emptySHA256Digest)(updateDigest)