Merge pull request #17449 from akka/wip-static-props-docs-∂π

=doc add props static method to IODocText
This commit is contained in:
Roland Kuhn 2015-05-11 17:21:48 +02:00
commit d5a9c2b0c0

View file

@ -41,6 +41,10 @@ public class IODocTest {
this.manager = manager; this.manager = manager;
} }
public static Props props(ActorRef manager) {
return Props.create(Server.class, manager);
}
@Override @Override
public void preStart() throws Exception { public void preStart() throws Exception {
final ActorRef tcp = Tcp.get(getContext().system()).manager(); final ActorRef tcp = Tcp.get(getContext().system()).manager();
@ -91,6 +95,10 @@ public class IODocTest {
final InetSocketAddress remote; final InetSocketAddress remote;
final ActorRef listener; final ActorRef listener;
public static Props props(InetSocketAddress remote, ActorRef listener) {
return Props.create(Client.class, remote, listener);
}
public Client(InetSocketAddress remote, ActorRef listener) { public Client(InetSocketAddress remote, ActorRef listener) {
this.remote = remote; this.remote = remote;
this.listener = listener; this.listener = listener;
@ -150,9 +158,9 @@ public class IODocTest {
new JavaTestKit(system) { new JavaTestKit(system) {
{ {
@SuppressWarnings("unused") @SuppressWarnings("unused")
final ActorRef server = system.actorOf(Props.create(Server.class, getRef()), "server1"); final ActorRef server = system.actorOf(Server.props(getRef()), "server1");
final InetSocketAddress listen = expectMsgClass(Bound.class).localAddress(); final InetSocketAddress listen = expectMsgClass(Bound.class).localAddress();
final ActorRef client = system.actorOf(Props.create(Client.class, listen, getRef()), "client1"); final ActorRef client = system.actorOf(Client.props(listen, getRef()), "client1");
final Connected c1 = expectMsgClass(Connected.class); final Connected c1 = expectMsgClass(Connected.class);
final Connected c2 = expectMsgClass(Connected.class); final Connected c2 = expectMsgClass(Connected.class);