Unwrap/strip 无形余积对象
Unwrap/strip Shapeless Coproduct objects
我有一个如下所示的域:
package object tryme {
type ALL = AlarmMessage :+: PassMessage :+: HeyMessage :+: CNil
}
import com.tryme._
trait PayloadKind
trait Command extends PayloadKind
trait Event extends PayloadKind
trait Message[+T <: PayloadKind] {
val id: String
val payload: T
}
case class Alarm(severity: Int) extends Event
case class Pass(reason: String) extends Event
case class Hey(order: String) extends Command
case class AlarmMessage(id: String, payload: Alarm) extends Message[Event]
case class PassMessage(id: String, payload: Pass) extends Message[Event]
case class HeyMessage(id: String, payload: Hey) extends Message[Command]
case class AvroMessage(
id: String,
cargo: ALL
)
如果我用 cargo = HeyMessage 创建一个 AvroMessage,我就能serialize/de-serialse成功。
当我检查反序列化的 AvroMessage 对象的货物字段时,它看起来像这样:
Inr(Inr(Inl(HeyMessage(art333,Hey(wow)))))
在Shapeless中,我如何unwrap/strip全部Inr/Inls?理想情况下,如果我可以避免的话,我不想关心(post 反序列化)有效负载是 HeyMessage(或任何其他类型)。我要把货物投到 Message[PayloadKind],但首先我需要打开它。
(我看到了类似问题的答案here,但我承认我不明白它是如何工作的,也无法适应它。)
您可以使用shapeless.ops.coproduct.Selector
val coproduct = Inr(Inr(Inl(HeyMessage(art333, Hey(wow)))))
Selector[ALL, HeyMessage].apply(coproduct).get
结果为 HeyMessage(art333,Hey(wow))
。
您可以使用 syntax
子包中的扩展方法:
import shapeless.syntax._
// select returns an Option
coproduct.select[HeyMessage].get
我有一个如下所示的域:
package object tryme {
type ALL = AlarmMessage :+: PassMessage :+: HeyMessage :+: CNil
}
import com.tryme._
trait PayloadKind
trait Command extends PayloadKind
trait Event extends PayloadKind
trait Message[+T <: PayloadKind] {
val id: String
val payload: T
}
case class Alarm(severity: Int) extends Event
case class Pass(reason: String) extends Event
case class Hey(order: String) extends Command
case class AlarmMessage(id: String, payload: Alarm) extends Message[Event]
case class PassMessage(id: String, payload: Pass) extends Message[Event]
case class HeyMessage(id: String, payload: Hey) extends Message[Command]
case class AvroMessage(
id: String,
cargo: ALL
)
如果我用 cargo = HeyMessage 创建一个 AvroMessage,我就能serialize/de-serialse成功。
当我检查反序列化的 AvroMessage 对象的货物字段时,它看起来像这样:
Inr(Inr(Inl(HeyMessage(art333,Hey(wow)))))
在Shapeless中,我如何unwrap/strip全部Inr/Inls?理想情况下,如果我可以避免的话,我不想关心(post 反序列化)有效负载是 HeyMessage(或任何其他类型)。我要把货物投到 Message[PayloadKind],但首先我需要打开它。
(我看到了类似问题的答案here,但我承认我不明白它是如何工作的,也无法适应它。)
您可以使用shapeless.ops.coproduct.Selector
val coproduct = Inr(Inr(Inl(HeyMessage(art333, Hey(wow)))))
Selector[ALL, HeyMessage].apply(coproduct).get
结果为 HeyMessage(art333,Hey(wow))
。
您可以使用 syntax
子包中的扩展方法:
import shapeless.syntax._
// select returns an Option
coproduct.select[HeyMessage].get