private <T> void resolveRequest(int requestId, T response, Throwable error) {
        Sinks.One<T> sink = (Sinks.One<T>) pendingRequestMap.remove(requestId);
        if (sink == null) {
            LOGGER.warn("Could not find a pending request with the ID ({}) for the response: {}",
                    requestId,
                    response);
            return;
        }
        if (error == null) {
            sink.tryEmitValue(response);
        } else {
            sink.tryEmitError(error);
        }
    }
Accept {@param requestBody} of ByteBuf so that we can send the same buffer to multiple peers

@implNote The method ensures {@param requestBody} will be released by 1
turms-server-common/src/main/java/im/turms/server/common/infra/cluster/service/rpc/RpcEndpoint.java