Reactive Client Server with Aeron transport

Aeron.java

// AeronProcessor as a server
AeronProcessor server = AeronProcessor.builder()
                .senderChannel("udp://localhost:12000")
                .receiverChannel("udp://localhost:12001")
                .senderOnly(true)
                .create();

// Read file bytes on server command        
IO.readFile("~/test.txt")
.subscribe(server);
                
// AeronProcessor as a client
AeronProcessor client = AeronProcessor.builder()
                .senderChannel("udp://localhost:12000")
                .receiverChannel("udp://localhost:12001")
                .receiverOnly(true)
                .create();

client.subscribe(Subscribers.unbounded((next, sub) -> System.out.println(next)));