MCPcopy Create free account
hub / github.com/e2wugui/zeze / sendAllOnlines

Method sendAllOnlines

ZezeJava/ZezeJava/src/main/java/Zeze/Game/Online.java:994–1002  ·  view source on GitHub ↗
(long roleId, @NotNull Protocol<?> p)

Source from the content-addressed store, hash-verified

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) {

Callers 2

Calls 14

canLogProtocolMethod · 0.95
logMethod · 0.95
getProviderWithOnlineMethod · 0.95
foreachOnlineMethod · 0.80
setLengthMethod · 0.80
getNameMethod · 0.65
getTypeIdMethod · 0.65
encodeMethod · 0.65
isEmptyMethod · 0.65
isRequestMethod · 0.45
sendDirectMethod · 0.45
appendMethod · 0.45

Tested by

no test coverage detected