RPCExample.hx

import pony.net.*;
import pony.net.rpc.*;
import pony.events.*;
import pony.time.MainLoop;

class RPCExample {

	private static function main():Void {
		MainLoop.init();
		var server = new ExampleProtocol(new SocketServer(12345));
		var client = new ExampleProtocol(new SocketClient(12345));
		server.onMessage.add((message:String) -> trace('Received: $message'));
		server.onMessage.add(MainLoop.stop);
		client.messageRemote('hello');
		MainLoop.start();
	}

}

class ExampleProtocol extends RPC<ExampleProtocol> implements IRPC {

	@:rpc public var onMessage:Signal1<String>;

}