斯卡拉特质类型不匹配

Question

我有，我用我的项目的一些卡夫卡频道层次：

我的基本特点是：

trait SendChannel[A, B] extends CommunicationChannel { 
    def send(data:A): B 
} 

现在我有一个共同的卡夫卡发送通道像

trait CommonKafkaSendChannel[A, B, Return] extends SendChannel[A, Return] { 
val channelProps: KafkaSendChannelProperties 
val kafkaProducer: Producer[String, B] 
override def close(): Unit = kafkaProducer.close() 
} 

现在有2个CommanKafkaSendChannel变体，一个是回调，一个是Future：

trait KafkaSendChannelWithFuture[A, B] extends CommonKafkaSendChannel[A, B, Future[RecordMetadata]] { 
override def send(data: A): Future[RecordMetadata] = Future { 
    kafkaProducer.send(new ProducerRecord[String, B](channelProps.topic)).get 
} 
} 

KafkaSendChannelWithCallback定义：

object KafkaSendChannelWithCallback { 

def apply[A, B](oChannelProps: KafkaSendChannelProperties, 
       oKafkaProducer: Producer[String, B], 
       oCallback: Callback): KafkaSendChannelWithCallback[A, B] = 
new KafkaSendChannelWithCallback[A,B] { 
    override val channelProps: KafkaSendChannelProperties = oChannelProps 
    override val kafkaProducer: Producer[String, B] = oKafkaProducer 
    override val callback: Callback = oCallback 
} 
} 

trait KafkaSendChannelWithCallback[A, B] extends CommonKafkaSendChannel[A, B, Unit] { 

    val callback: Callback 

override def send(data: A): Unit = 
kafkaProducer.send(new ProducerRecord[String, B](channelProps.topic), callback) 
} 

现在基于所述配置值I选择通道的上下面等运行时适当的类型。我创建右信道类型的演员，将数据发送到卡夫卡：

val sendChannel = kafkaChannel.channel(config, actorSystem).fold(
    error => { 
     logger.error("Exception while instantiating the KafkaSendChannel") 
     throw error 
    }, 
    success => success 
) 

actor = actorSystem.actorOf(IngestionActor.props(config, sendChannel), name = ACTOR_NAME) 

演员的定义：

object IngestionRouterActor { 
    def props[V](config: Config, sendChannel: SendChannel[V, Unit]): Props = 
Props(classOf[IngestionActor[V]], config, sendChannel) 
} 

问题是，当我使用KafkaSendChannelWithCallback我的代码正常编译但是当我使用KafkaSendChannelWithFuture它给我下面的错误actor =声明：

[error] IngestionActor.scala：32：模式类型与预期类型不兼容; [错误]实测值：KafkaSendChannelWithFuture [字符串，V] [错误]需要：SendChannel [V，单位]

由于两个信道定义是从SendChannel延长，此代码应编译没有任何错误。我不确定它为什么不编译。谢谢

Answer 1

Props对于IngestionActor需要SendChannel[V, Unit]。将KafkaSendChannelWithCallback传递给此参数的原因是因为它是SendChannel[V, Unit]。另一方面，是SendChannel[V, Future[RecordMetadata]]。 A SendChannel[V, Future[RecordMetadata]]是而不是 a SendChannel[V, Unit]。

一种选择是重新定义Props采取SendChannel[V, Any]，因为Any既是Unit和Future的超类型：

def props[V](config: Config, sendChannel: SendChannel[V, Any]): Props = ??? 

此时，编译器仍然不高兴，因为SendChannel，作为一个泛型类型，默认情况下是不变的。换句话说，SendChannel[V, Unit]和SendChannel[V, Future[RecordMetadata]]都不是SendChannel[V, Any]类型。

要改变这种状况，就第2类参数SendChannel协变（在B前面添加+）：

trait SendChannel[A, +B] extends CommunicationChannel { 
    def send(data: A): B 
}