(long roleId, @NotNull Protocol<?> p)
| 932 | |
| 933 | // 在指定Online上发送 |
| 934 | public void sendOnline(long roleId, @NotNull Protocol<?> p) { |
| 935 | if (p instanceof Rpc && p.isRequest()) |
| 936 | throw new IllegalArgumentException(p.getClass().getName() + " is rpc. please use sendRpc/sendOnlineRpc"); |
| 937 | var typeId = p.getTypeId(); |
| 938 | if (AsyncSocket.ENABLE_PROTOCOL_LOG && AsyncSocket.canLogProtocol(typeId)) |
| 939 | AsyncSocket.log("Send", roleId, multiInstanceName, p); |
| 940 | sendDirect(roleId, typeId, new Binary(p.encode()), false); |
| 941 | } |
| 942 | |
| 943 | // 优先在上下文中的Online上发送 |
| 944 | public <A extends Serializable, R extends Serializable> void sendRpc( |
no test coverage detected