(long roleId, @NotNull Protocol<?> p)
| 992 | |
| 993 | // 尝试给所有Onlines发送,可在任意Online上执行 |
| 994 | public void sendAllOnlines(long roleId, @NotNull Protocol<?> p) { |
| 995 | if (p instanceof Rpc && p.isRequest()) |
| 996 | throw new IllegalArgumentException(p.getClass().getName() + " is rpc. please use sendRpc/sendOnlineRpc"); |
| 997 | var typeId = p.getTypeId(); |
| 998 | if (AsyncSocket.ENABLE_PROTOCOL_LOG && AsyncSocket.canLogProtocol(typeId)) |
| 999 | AsyncSocket.log("Send", roleId, "*", p); |
| 1000 | var data = new Binary(p.encode()); |
| 1001 | getProviderWithOnline().foreachOnline(online -> online.sendDirect(roleId, typeId, data, true)); |
| 1002 | } |
| 1003 | |
| 1004 | // 优先在上下文中的Online上发送 |
| 1005 | public void send(@NotNull Collection<Long> roleIds, @NotNull Protocol<?> p) { |
no test coverage detected