getChannel

val subscriber = _events.getSubscriber()
subscriber.subscribeLocally({
    setChannel("subscription channel")
    setId("subscription id")
}) {
    _console.log("sub.kts 收到事件", it.getData(), it.getTime(), it.getChannel())
}
subscriber.subscribeGlobally({
    setChannel("subscription channel")
    setId("subscription id")
}) {
    _console.log("sub.kts 收到事件", it.getData(), it.getTime(), it.getChannel())
}
val mainThread = _script.getThreads().getMain()!!
val timer = mainThread.getTimer()!!
timer.setTimeout({
    // 保持脚本3秒钟不结束
}, 3000)

def subscriber = $events.getSubscriber()
subscriber.subscribeLocally({
    setChannel("subscription channel")
    setId("subscription id")
}) {
    $console.log("sub.groovy 收到事件", it.getData(), it.getTime(), it.getChannel())
}
subscriber.subscribeGlobally({
    setChannel("subscription channel")
    setId("subscription id")
}) {
    $console.log("sub.groovy 收到事件", it.getData(), it.getTime(), it.getChannel())
}
def mainThread = $script.getThreads().getMain()
def timer = mainThread.getTimer()
timer.setTimeout({
    // 保持脚本3秒钟不结束
}, 3000)

let subscriber = $events.getSubscriber()
subscriber.subscribeLocally((subscription) => {
    subscription.setChannel("subscription channel")
    subscription.setId("subscription id")
}, (it) => {
    $console.log("sub.js 收到事件", it.getData(), it.getTime(), it.getChannel())
})
subscriber.subscribeGlobally((subscription) => {
    subscription.setChannel("subscription channel")
    subscription.setId("subscription id")
}, (it) => {
    $console.log("sub.js 收到事件", it.getData(), it.getTime(), it.getChannel())
})
let mainThread = $script.getThreads().getMain()
let timer = mainThread.getTimer()
timer.setTimeout(() => {
    // 保持脚本3秒钟不结束
}, 3000)

local subscriber = _events:getSubscriber()
subscriber:subscribeLocally(function(subscription)
    subscription:setChannel("subscription channel")
    subscription:setId("subscription id")
end, function(it)
    _console:log("sub.lua 收到事件", it:getData(), it:getTime(), it:getChannel())
end)
subscriber:subscribeGlobally(function(subscription)
    subscription:setChannel("subscription channel")
    subscription:setId("subscription id")
end, function(it)
    _console:log("sub.lua 收到事件", it:getData(), it:getTime(), it:getChannel())
end)
local mainThread = _script:getThreads():getMain()
local timer = mainThread:getTimer()
timer:setTimeout(function()
    -- 保持脚本3秒钟不结束
end, 3000)

<?php
$subscriber = $events->getSubscriber();
$subscriber->subscribeLocally(function ($subscription) {
    $subscription->setChannel("subscription channel");
    $subscription->setId("subscription id");
}, function ($it) use ($console) {
    $console->log("sub.php 收到事件", $it->getData(), $it->getTime(), $it->getChannel());
});
$subscriber->subscribeGlobally(function ($subscription) {
    $subscription->setChannel("subscription channel");
    $subscription->setId("subscription id");
}, function ($it) use ($console) {
    $console->log("sub.php 收到事件", $it->getData(), $it->getTime(), $it->getChannel());
});
$mainThread = $script->getThreads()->getMain();
$timer = $mainThread->getTimer();
$timer->setTimeout(function () {
    // 保持脚本3秒钟不结束
}, 3000);

subscriber = _events.getSubscriber()

def fn1(subscription):
    subscription.setChannel("subscription channel")
    subscription.setId("subscription id")

def fn2(it):
    _console.log("sub.py 收到事件", it.getData(), it.getTime(), it.getChannel())

subscriber.subscribeLocally(fn1, fn2)

def fn3(subscription):
    subscription.setChannel("subscription channel")
    subscription.setId("subscription id")

def fn4(it):
    _console.log("sub.py 收到事件", it.getData(), it.getTime(), it.getChannel())

subscriber.subscribeGlobally(fn3, fn4)
mainThread = _script.getThreads().getMain()
timer = mainThread.getTimer()

def fn5(params):
    # 保持脚本3秒钟不结束
    pass

timer.setTimeout(fn5, 3000)

# encoding: utf-8
subscriber = $events.getSubscriber()
subscriber.subscribeLocally(lambda { |subscription|
  subscription.setChannel("subscription channel")
  subscription.setId("subscription id")
}) { |it|
  $console.log("sub.rb 收到事件", it.getData(), it.getTime(), it.getChannel())
}
subscriber.subscribeGlobally(lambda { |subscription|
  subscription.setChannel("subscription channel")
  subscription.setId("subscription id")
}) { |it|
  $console.log("sub.rb 收到事件", it.getData(), it.getTime(), it.getChannel())
}
mainThread = $script.getThreads().getMain()
timer = mainThread.getTimer()
timer.setTimeout(lambda { |params|
  # 保持脚本3秒钟不结束
}, 3000)

Last modified: 29 April 2025