相关疑难解决方法(0)

我有一个Akka Streams Source,我希望根据谓词分成两个来源.

例如有一个源(有意简化类型):

val source: Source[Either[Throwable, String], NotUsed] = ???

还有两种方法:

def handleSuccess(source: Source[String, NotUsed]): Future[Unit] = ???
def handleFailure(source: Source[Throwable, NotUsed]): Future[Unit] = ???

我希望能够将source根据_.isRight谓词拆分并将正确的部分传递给handleSuccess方法并将部分传递给handleFailure方法.

我尝试使用Broadcast分离器,但最后需要Sinks.