我正在寻找一种方法来处理如下例子的协议:
case class Request(bodyType: Int,foo: Int,bar: Int,body: RequestBody) sealed trait RequestBody case class Read(key: String) extends RequestBody case class Write(key: String,value: Array[Byte]) extends RequestBody
这里,bodyType == 0代表Read,bodyType!= 0代表Write.
注意,有一些字段将鉴别器与鉴别值分开.
我见过an example with byte-ordering.
但据我所知,这种“鱿鱼”编码鉴别器不会往返.
解决这个问题的正确方法是什么?
解决方法
有几种方法可以做到,但这是我用过的方法:
import scodec._ import scodec.codecs._ import scodec.bits._ case class Request(bodyType: Int,body: RequestBody) sealed trait RequestBody case class Read(key: String) extends RequestBody object Read { implicit val codec: Codec[Read] = ("key" | utf8).as[Read] implicit val discriminator: discriminator[RequestBody,Read,Int] = discriminator(0) } case class Write(key: String,value: ByteVector) extends RequestBody object Write { implicit val codec: Codec[Write] = { ("key" | utf8 ) :: ("value" | bytes ) }.as[Write] implicit val discriminator: discriminator[RequestBody,Write,Int] = discriminator(1) } object Request { implicit val codec: Codec[Request] = { ("bodyType" | uint16 ).flatPrepend { bodyType => ("foo" | uint16 ) :: ("bar" | uint16 ) :: ("body" | Codec.coproduct[RequestBody].discriminatedBy(provide(bodyType)).auto) }}.as[Request] }
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。