Documentation / @agentick/kernel / Channel
Class: Channel
Defined in: kernel/src/channel.ts:88
Core Channel primitive. Works standalone in any Node environment. Uses EventEmitter internally for pub/sub.
Constructors
Constructor
new Channel(
name):Channel
Defined in: kernel/src/channel.ts:101
Parameters
name
string
Returns
Channel
Properties
name
readonlyname:string
Defined in: kernel/src/channel.ts:101
Methods
destroy()
destroy():
void
Defined in: kernel/src/channel.ts:230
Cleanup: remove all subscribers and pending requests.
Returns
void
getSubscriberCount()
getSubscriberCount():
number
Defined in: kernel/src/channel.ts:223
Get the number of active subscribers.
Returns
number
publish()
publish(
event):void
Defined in: kernel/src/channel.ts:106
Publish an event to the channel.
Parameters
event
Returns
void
subscribe()
subscribe(
handler): () =>void
Defined in: kernel/src/channel.ts:167
Subscribe to events on this channel.
Parameters
handler
(event) => void
Returns
Unsubscribe function
():
void
Returns
void
waitForResponse()
waitForResponse(
requestId,timeoutMs?):Promise<ChannelEvent>
Defined in: kernel/src/channel.ts:183
Wait for a response to a specific request. Used by tools/components for bidirectional communication.
Parameters
requestId
string
The request ID to wait for
timeoutMs?
number = 30000
Timeout in milliseconds (default: 30000)
Returns
Promise<ChannelEvent>
Promise that resolves when response is received