本文整理了Java中akka.stream.javadsl.Source.viaMat()方法的一些代码示例，展示了Source.viaMat()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Source.viaMat()方法的具体详情如下：
包路径：akka.stream.javadsl.Source
类名称：Source
方法名：viaMat

Source.viaMat介绍

暂无

代码示例

代码示例来源：origin: apptik/RHub

@Override
public Removable addUpstream(Source<Object, NotUsed> publisher) {
  UniqueKillSwitch killSwitch =
      publisher.viaMat(busFlow, Keep.right())
          .to(Sink.ignore())
          .run(mat);
  subscriptions.put(publisher, killSwitch);
  return () -> AkkaHubProxy.this.removeUpstream(publisher);
}

代码示例来源：origin: apptik/RHub

@Override
public void emit(Object event) {
  Source.single(event).viaMat(busFlow, Keep.right())
      .to(Sink.ignore())
      .run(mat);
}

代码示例来源：origin: org.eclipse.ditto/ditto-services-connectivity-messaging

mqttStreamSource.viaMat(consumerKillSwitch.flow(), Keep.left())
    .map(this::countConsumedMessage)
    .toMat(consumerLoadBalancer, Keep.left())

代码示例来源：origin: eclipse/ditto

mqttStreamSource.viaMat(consumerKillSwitch.flow(), Keep.left())
    .map(this::countConsumedMessage)
    .toMat(consumerLoadBalancer, Keep.left())