将Akka源码转换为RxJava2 Flowable？

import akka.actor.AbstractActor;
import akka.actor.ActorRef;
import akka.actor.ActorSystem;
import akka.actor.Props;
import io.reactivex.Flowable;
import io.reactivex.schedulers.Schedulers;

public class AkkaToRxJavaExample {

    public static void main(String[] args) {
        // 创建Actor系统
        ActorSystem system = ActorSystem.create("AkkaToRxJavaExample");

        // 创建一个Actor
        ActorRef actor = system.actorOf(Props.create(MyActor.class));

        // 将Actor的消息转换为Flowable
        Flowable<String> flowable = Flowable.fromPublisher(actor::tell)
                .subscribeOn(Schedulers.io());

        // 对Flowable进行处理
        flowable.filter(s -> s.startsWith("A"))
                .map(String::toUpperCase)
                .subscribe(System.out::println);

        // 发送消息给Actor
        actor.tell("Hello", ActorRef.noSender());
        actor.tell("Akka", ActorRef.noSender());
        actor.tell("RxJava", ActorRef.noSender());

        // 关闭Actor系统
        system.terminate();
    }

    static class MyActor extends AbstractActor {
        @Override
        public Receive createReceive() {
            return receiveBuilder()
                    .match(String.class, message -> {
                        // 将接收到的消息发送给Flowable
                        getSender().tell(message, getSelf());
                    })
                    .build();
        }
    }
}