ModuleClient class
IoT Hub apparaatclient die wordt gebruikt om een apparaat te verbinden met een Azure IoT-hub.
Gebruikers van de SDK moeten een van de factory-methoden aanroepen, fromConnectionString of fromSharedAccessSignature om een IoT Hub apparaatclient te maken.
- Extends
-
InternalClient
Overgenomen eigenschappen
capture |
Waarde: booleaanse waarde Wijzig de standaardoptie |
capture |
Waarde: Meer informatie over het schrijven van een aangepaste |
default |
Standaard kan een maximum aan Wees voorzichtig bij het instellen van de Dit is geen harde limiet. Met
De De verzonden waarschuwing kan worden geïnspecteerd met |
error |
Dit symbool wordt gebruikt om een listener te installeren voor het bewaken Als u een listener installeert met dit symbool, verandert het gedrag niet zodra een |
Methoden
close() | |
close(Callback<Disconnected>) | Hiermee wordt de transportverbinding gesloten en worden de clientresources vernietigd. Opmerking: na het aanroepen van deze methode kan het ModuleClient-object niet opnieuw worden gebruikt. |
from |
Hiermee maakt u een IoT Hub moduleclient op basis van de opgegeven verificatiemethode en met behulp van het opgegeven transporttype. |
from |
Hiermee maakt u een IoT Hub apparaatclient van de opgegeven verbindingsreeks met behulp van het opgegeven transporttype. |
from |
|
from |
Hiermee maakt u een IoT Hub moduleclient met behulp van configuratiegegevens uit de omgeving. Als er een omgevingsvariabele met de naam
|
from |
Hiermee maakt u een IoT Hub moduleclient van de opgegeven Shared Access Signature met behulp van het opgegeven transporttype. |
invoke |
|
invoke |
Hiermee wordt een methode aangeroepen op een downstreamapparaat of op een andere module op hetzelfde IoTEdge-apparaat. Houd er rekening mee dat deze functie alleen werkt wanneer de module wordt uitgevoerd als onderdeel van een IoTEdge-apparaat. |
invoke |
|
invoke |
|
on |
Registreert een callback voor een methode met de naam |
send |
|
send |
Hiermee wordt een gebeurtenis naar de opgegeven module-uitvoer verzonden |
send |
|
send |
Hiermee wordt een matrix met gebeurtenissen naar de opgegeven module-uitvoer verzonden |
set |
|
set |
Geeft opties door aan het |
Overgenomen methoden
abandon(Message) | |
abandon(Message, Callback<Message |
|
add |
Luistert eenmaal naar de Luisteren naar de Met deze API kunt u veilig s in Node.js API's gebruiken Retourneert een wegwerp, zodat deze gemakkelijker kan worden afgemeld.
|
add |
Alias voor |
complete(Message) | |
complete(Message, Callback<Message |
|
emit<K>(string | symbol, Any |
Roept synchroon alle listeners aan die zijn geregistreerd voor de gebeurtenis met de naam Retourneert
|
event |
Retourneert een matrix met de gebeurtenissen waarvoor de emitter listeners heeft geregistreerd. De waarden in de matrix zijn tekenreeksen of
|
get |
Retourneert een kopie van de matrix met listeners voor de gebeurtenis met de naam Voor Voor
|
get |
Retourneert de huidige maximale listenerwaarde voor de |
get |
Retourneert het momenteel ingestelde maximumaantal listeners. Voor Voor
|
get |
|
get |
|
listener |
Een klassemethode die het aantal listeners retourneert voor de opgegeven
|
listener |
Retourneert het aantal listeners dat luistert naar de gebeurtenis met de naam |
listeners<K>(string | symbol) | Retourneert een kopie van de matrix met listeners voor de gebeurtenis met de naam
|
off<K>(string | symbol, (args: any[]) => void) | Alias voor |
on(Event |
Retourneert een Een
|
on<K>(string | symbol, (args: any[]) => void) | Hiermee voegt u de
Retourneert een verwijzing naar de Gebeurtenislisteners worden standaard aangeroepen in de volgorde waarin ze worden toegevoegd. De
|
once(Event |
Hiermee maakt u een Deze methode is opzettelijk algemeen en werkt met de EventTarget-interface van het webplatform, die geen speciale
De speciale verwerking van de
Een
|
once(Event |
|
once<K>(string | symbol, (args: any[]) => void) | Voegt een eenmalige
Retourneert een verwijzing naar de Gebeurtenislisteners worden standaard aangeroepen in de volgorde waarin ze worden toegevoegd. De
|
open() | |
open(Callback<Connected>) | |
prepend |
Hiermee voegt u de
Retourneert een verwijzing naar de |
prepend |
Hiermee voegt u een eenmalige
Retourneert een verwijzing naar de |
raw |
Retourneert een kopie van de matrix met listeners voor de gebeurtenis met de naam
|
reject(Message) | |
reject(Message, Callback<Message |
|
remove |
Hiermee verwijdert u alle listeners of die van de opgegeven Het is een slechte gewoonte om listeners te verwijderen die elders in de code zijn toegevoegd, met name wanneer het Retourneert een verwijzing naar de |
remove |
Hiermee verwijdert u de opgegeven
Zodra een gebeurtenis wordt verzonden, worden alle listeners die eraan zijn gekoppeld op het moment van verzenden in de volgorde aangeroepen. Dit betekent dat aanroepen
Omdat listeners worden beheerd met behulp van een interne matrix, verandert het aanroepen hiervan de positieindexen van elke listener die is geregistreerd nadat de listener is verwijderd. Dit heeft geen invloed op de volgorde waarin listeners worden aangeroepen, maar het betekent dat kopieën van de listenermatrix die door de Wanneer één functie meerdere keren als handler is toegevoegd voor één gebeurtenis (zoals in het onderstaande voorbeeld),
Retourneert een verwijzing naar de |
send |
|
send |
|
send |
|
send |
|
set |
Retourneert een verwijzing naar de |
set |
|
set |
Hiermee stelt u het beleid voor opnieuw proberen dat door de client wordt gebruikt voor alle bewerkingen. De standaardwaarde is ExponentialBackoffWithJitter. |
set |
|
set |
|
update |
|
[capture |
Details van overgenomen eigenschap
captureRejections
Waarde: booleaanse waarde
Wijzig de standaardoptie captureRejections
voor alle nieuwe EventEmitter
objecten.
static captureRejections: boolean
Waarde van eigenschap
boolean
Overgenomen van InternalClient.captureRejections
captureRejectionSymbol
Waarde: Symbol.for('nodejs.rejection')
Meer informatie over het schrijven van een aangepaste rejection handler
.
static captureRejectionSymbol: typeof captureRejectionSymbol
Waarde van eigenschap
typeof captureRejectionSymbol
Overgenomen van InternalClient.captureRejectionSymbol
defaultMaxListeners
Standaard kan een maximum aan 10
listeners worden geregistreerd voor elke gebeurtenis. Deze limiet kan worden gewijzigd voor afzonderlijke EventEmitter
exemplaren met behulp van de emitter.setMaxListeners(n)
-methode. Als u de standaardwaarde voor alleEventEmitter
exemplaren wilt wijzigen, kan de events.defaultMaxListeners
eigenschap worden gebruikt. Als deze waarde geen positief getal is, wordt een RangeError
gegenereerd.
Wees voorzichtig bij het instellen van de events.defaultMaxListeners
omdat de wijziging van invloed is op alleEventEmitter
exemplaren, inclusief de exemplaren die zijn gemaakt voordat de wijziging wordt aangebracht. Aanroepen emitter.setMaxListeners(n)
heeft echter nog steeds voorrang op events.defaultMaxListeners
.
Dit is geen harde limiet. Met EventEmitter
het exemplaar kunnen meer listeners worden toegevoegd, maar er wordt een traceringswaarschuwing naar stderr verzonden die aangeeft dat er een 'mogelijk EventEmitter-geheugenlek' is gedetecteerd. Voor één EventEmitter
, kunnen de emitter.getMaxListeners()
methoden en emitter.setMaxListeners()
worden gebruikt om deze waarschuwing tijdelijk te voorkomen:
import { EventEmitter } from 'node:events';
const emitter = new EventEmitter();
emitter.setMaxListeners(emitter.getMaxListeners() + 1);
emitter.once('event', () => {
// do stuff
emitter.setMaxListeners(Math.max(emitter.getMaxListeners() - 1, 0));
});
De --trace-warnings
opdrachtregelvlag kan worden gebruikt om de stacktracering voor dergelijke waarschuwingen weer te geven.
De verzonden waarschuwing kan worden geïnspecteerd met process.on('warning')
en heeft de aanvullende emitter
eigenschappen , type
en count
, die respectievelijk verwijzen naar het exemplaar van de gebeurtenisverzender, de naam van de gebeurtenis en het aantal gekoppelde listeners.
De name
eigenschap is ingesteld op 'MaxListenersExceededWarning'
.
static defaultMaxListeners: number
Waarde van eigenschap
number
Overgenomen van InternalClient.defaultMaxListeners
errorMonitor
Dit symbool wordt gebruikt om een listener te installeren voor het bewaken 'error'
van gebeurtenissen. Listeners die met dit symbool zijn geïnstalleerd, worden aangeroepen voordat de normale 'error'
listeners worden aangeroepen.
Als u een listener installeert met dit symbool, verandert het gedrag niet zodra een 'error'
gebeurtenis wordt verzonden. Daarom loopt het proces nog steeds vast als er geen reguliere 'error'
listener is geïnstalleerd.
static errorMonitor: typeof errorMonitor
Waarde van eigenschap
typeof errorMonitor
Overgenomen van InternalClient.errorMonitor
Methodedetails
close()
function close(): Promise<Disconnected>
Retouren
Promise<Disconnected>
close(Callback<Disconnected>)
Hiermee wordt de transportverbinding gesloten en worden de clientresources vernietigd.
Opmerking: na het aanroepen van deze methode kan het ModuleClient-object niet opnieuw worden gebruikt.
function close(closeCallback?: Callback<Disconnected>)
Parameters
- closeCallback
-
Callback<Disconnected>
Optionele functie om aan te roepen zodra de verbinding met het transport is verbroken en de client is gesloten.
fromAuthenticationProvider(AuthenticationProvider, any)
Hiermee maakt u een IoT Hub moduleclient op basis van de opgegeven verificatiemethode en met behulp van het opgegeven transporttype.
static function fromAuthenticationProvider(authenticationProvider: AuthenticationProvider, transportCtor: any): ModuleClient
Parameters
- authenticationProvider
-
AuthenticationProvider
Object dat wordt gebruikt om de verificatieparameters voor de IoT-hub op te halen.
- transportCtor
-
any
Het transportprotocol dat wordt gebruikt om verbinding te maken met IoT Hub.
Retouren
fromConnectionString(string, any)
Hiermee maakt u een IoT Hub apparaatclient van de opgegeven verbindingsreeks met behulp van het opgegeven transporttype.
static function fromConnectionString(connStr: string, transportCtor: any): ModuleClient
Parameters
- connStr
-
string
Een verbindingsreeks die machtigingen voor 'apparaatverbinding' bevat voor een IoT-hub.
- transportCtor
-
any
Een transportconstructor.
Retouren
fromEnvironment(any)
static function fromEnvironment(transportCtor: any): Promise<ModuleClient>
Parameters
- transportCtor
-
any
Retouren
Promise<ModuleClient>
fromEnvironment(any, Callback<ModuleClient>)
Hiermee maakt u een IoT Hub moduleclient met behulp van configuratiegegevens uit de omgeving.
Als er een omgevingsvariabele met de naam EdgeHubConnectionString
of IotHubConnectionString
bestaat, wordt die waarde gebruikt en is het gedrag identiek aan het aanroepen fromConnectionString
van het doorgeven van die in. Als deze omgevingsvariabelen niet bestaan, moeten de volgende variabelen worden gedefinieerd:
- IOTEDGE_WORKLOADURI URI for iotedged's workload API
- IOTEDGE_DEVICEID Device identifier
- IOTEDGE_MODULEID Module identifier
- IOTEDGE_MODULEGENERATIONID Module generation identifier
- IOTEDGE_IOTHUBHOSTNAME IoT Hub host name
- IOTEDGE_AUTHSCHEME Authentication scheme to use; must be "sasToken"
static function fromEnvironment(transportCtor: any, callback?: Callback<ModuleClient>)
Parameters
- transportCtor
-
any
Het transportprotocol dat wordt gebruikt om verbinding te maken met IoT Hub.
- callback
-
Callback<ModuleClient>
Optionele callback om aan te roepen wanneer de ModuleClient is gemaakt of als er een fout optreedt tijdens het maken van de client.
fromSharedAccessSignature(string, any)
Hiermee maakt u een IoT Hub moduleclient van de opgegeven Shared Access Signature met behulp van het opgegeven transporttype.
static function fromSharedAccessSignature(sharedAccessSignature: string, transportCtor: any): ModuleClient
Parameters
- sharedAccessSignature
-
string
Een shared access signature die machtigingen voor 'apparaatverbinding' bevat voor een IoT-hub.
- transportCtor
-
any
Retouren
invokeMethod(string, MethodParams)
function invokeMethod(deviceId: string, methodParams: MethodParams): Promise<MethodResult>
Parameters
- deviceId
-
string
- methodParams
-
MethodParams
Retouren
Promise<MethodResult>
invokeMethod(string, MethodParams, Callback<MethodResult>)
Hiermee wordt een methode aangeroepen op een downstreamapparaat of op een andere module op hetzelfde IoTEdge-apparaat. Houd er rekening mee dat deze functie alleen werkt wanneer de module wordt uitgevoerd als onderdeel van een IoTEdge-apparaat.
function invokeMethod(deviceId: string, methodParams: MethodParams, callback?: Callback<MethodResult>)
Parameters
- deviceId
-
string
doelapparaat-id
- methodParams
-
MethodParams
parameters van de aanroep van de directe methode
- callback
-
Callback<MethodResult>
optionele callback die wordt aangeroepen met een foutobject of het resultaat van de methodeaanroep.
invokeMethod(string, string, MethodParams)
function invokeMethod(deviceId: string, moduleId: string, methodParams: MethodParams): Promise<MethodResult>
Parameters
- deviceId
-
string
- moduleId
-
string
- methodParams
-
MethodParams
Retouren
Promise<MethodResult>
invokeMethod(string, string, MethodParams, Callback<MethodResult>)
function invokeMethod(deviceId: string, moduleId: string, methodParams: MethodParams, callback: Callback<MethodResult>)
Parameters
- deviceId
-
string
- moduleId
-
string
- methodParams
-
MethodParams
- callback
-
Callback<MethodResult>
onMethod(string, DoubleValueCallback<DeviceMethodRequest, DeviceMethodResponse>)
Registreert een callback voor een methode met de naam methodName
.
function onMethod(methodName: string, callback: DoubleValueCallback<DeviceMethodRequest, DeviceMethodResponse>)
Parameters
- methodName
-
string
Naam van de methode die wordt verwerkt door de callback
- callback
-
DoubleValueCallback<DeviceMethodRequest, DeviceMethodResponse>
Functie die moet worden aangeroepen wanneer een methodeaanvraag voor de aangeroepen methodName
methode wordt ontvangen.
sendOutputEvent(string, Message)
function sendOutputEvent(outputName: string, message: Message): Promise<MessageEnqueued>
Parameters
- outputName
-
string
- message
- Message
Retouren
Promise<MessageEnqueued>
sendOutputEvent(string, Message, Callback<MessageEnqueued>)
Hiermee wordt een gebeurtenis naar de opgegeven module-uitvoer verzonden
function sendOutputEvent(outputName: string, message: Message, callback?: Callback<MessageEnqueued>)
Parameters
- outputName
-
string
Naam van de uitvoer waar de gebeurtenis naartoe moet worden verzonden
- message
- Message
Bericht dat moet worden verzonden naar de opgegeven uitvoer
- callback
-
Callback<MessageEnqueued>
Optionele functie om aan te roepen wanneer de bewerking in de wachtrij is geplaatst.
sendOutputEventBatch(string, Message[])
function sendOutputEventBatch(outputName: string, messages: Message[]): Promise<MessageEnqueued>
Parameters
- outputName
-
string
- messages
-
Message[]
Retouren
Promise<MessageEnqueued>
sendOutputEventBatch(string, Message[], Callback<MessageEnqueued>)
Hiermee wordt een matrix met gebeurtenissen naar de opgegeven module-uitvoer verzonden
function sendOutputEventBatch(outputName: string, messages: Message[], callback?: Callback<MessageEnqueued>)
Parameters
- outputName
-
string
Naam van de uitvoer waar de gebeurtenissen naartoe moeten worden verzonden
- messages
-
Message[]
- callback
-
Callback<MessageEnqueued>
Functie om aan te roepen wanneer de bewerkingen in de wachtrij zijn geplaatst.
setOptions(DeviceClientOptions)
function setOptions(options: DeviceClientOptions): Promise<TransportConfigured>
Parameters
- options
- DeviceClientOptions
Retouren
Promise<TransportConfigured>
setOptions(DeviceClientOptions, Callback<TransportConfigured>)
Geeft opties door aan het ModuleClient
object dat kan worden gebruikt om het transport te configureren.
function setOptions(options: DeviceClientOptions, done?: Callback<TransportConfigured>)
Parameters
- options
- DeviceClientOptions
- done
-
Callback<TransportConfigured>
Optionele callback om aan te roepen zodra de opties zijn ingesteld.
Details overgenomen methode
abandon(Message)
function abandon(message: Message): Promise<MessageAbandoned>
Parameters
- message
- Message
Retouren
Promise<MessageAbandoned>
Overgenomen van InternalClient.abandon
abandon(Message, Callback<MessageAbandoned>)
function abandon(message: Message, abandonCallback: Callback<MessageAbandoned>)
Parameters
- message
- Message
- abandonCallback
-
Callback<MessageAbandoned>
Overgenomen van InternalClient.abandon
addAbortListener(AbortSignal, (event: Event) => void)
Luistert eenmaal naar de abort
gebeurtenis op de opgegeven signal
.
Luisteren naar de abort
gebeurtenis bij afbrekingssignalen is onveilig en kan leiden tot resourcelekken omdat een andere derde partij met het signaal kan aanroepen e.stopImmediatePropagation()
. Helaas kan Node.js dit niet wijzigen omdat dit in strijd is met de webstandaard. Bovendien kunt u met de oorspronkelijke API gemakkelijk vergeten listeners te verwijderen.
Met deze API kunt u veilig s in Node.js API's gebruiken AbortSignal
door deze twee problemen op te lossen door naar de gebeurtenis te luisteren, stopImmediatePropagation
zodat de listener niet kan worden uitgevoerd.
Retourneert een wegwerp, zodat deze gemakkelijker kan worden afgemeld.
import { addAbortListener } from 'node:events';
function example(signal) {
let disposable;
try {
signal.addEventListener('abort', (e) => e.stopImmediatePropagation());
disposable = addAbortListener(signal, (e) => {
// Do something when signal is aborted.
});
} finally {
disposable?.[Symbol.dispose]();
}
}
static function addAbortListener(signal: AbortSignal, resource: (event: Event) => void): Disposable
Parameters
- signal
-
AbortSignal
- resource
-
(event: Event) => void
Retouren
Disposable
Wegwerp dat de abort
listener verwijdert.
Overgenomen van InternalClient.addAbortListener
addListener<K>(string | symbol, (args: any[]) => void)
Alias voor emitter.on(eventName, listener)
.
function addListener<K>(eventName: string | symbol, listener: (args: any[]) => void): ModuleClient
Parameters
- eventName
-
string | symbol
- listener
-
(args: any[]) => void
Retouren
Overgenomen van InternalClient.addListener
complete(Message)
function complete(message: Message): Promise<MessageCompleted>
Parameters
- message
- Message
Retouren
Promise<MessageCompleted>
Overgenomen van InternalClient.complete
complete(Message, Callback<MessageCompleted>)
function complete(message: Message, completeCallback: Callback<MessageCompleted>)
Parameters
- message
- Message
- completeCallback
-
Callback<MessageCompleted>
Overgenomen van InternalClient.complete
emit<K>(string | symbol, AnyRest)
Roept synchroon alle listeners aan die zijn geregistreerd voor de gebeurtenis met de naam eventName
, in de volgorde waarin ze zijn geregistreerd, waarbij de opgegeven argumenten aan elk worden doorgegeven.
Retourneert true
als de gebeurtenis listeners had, false
anders.
import { EventEmitter } from 'node:events';
const myEmitter = new EventEmitter();
// First listener
myEmitter.on('event', function firstListener() {
console.log('Helloooo! first listener');
});
// Second listener
myEmitter.on('event', function secondListener(arg1, arg2) {
console.log(`event with parameters ${arg1}, ${arg2} in second listener`);
});
// Third listener
myEmitter.on('event', function thirdListener(...args) {
const parameters = args.join(', ');
console.log(`event with parameters ${parameters} in third listener`);
});
console.log(myEmitter.listeners('event'));
myEmitter.emit('event', 1, 2, 3, 4, 5);
// Prints:
// [
// [Function: firstListener],
// [Function: secondListener],
// [Function: thirdListener]
// ]
// Helloooo! first listener
// event with parameters 1, 2 in second listener
// event with parameters 1, 2, 3, 4, 5 in third listener
function emit<K>(eventName: string | symbol, args: AnyRest): boolean
Parameters
- eventName
-
string | symbol
- args
-
AnyRest
Retouren
boolean
Overgenomen van InternalClient.emit
eventNames()
Retourneert een matrix met de gebeurtenissen waarvoor de emitter listeners heeft geregistreerd. De waarden in de matrix zijn tekenreeksen of Symbol
s.
import { EventEmitter } from 'node:events';
const myEE = new EventEmitter();
myEE.on('foo', () => {});
myEE.on('bar', () => {});
const sym = Symbol('symbol');
myEE.on(sym, () => {});
console.log(myEE.eventNames());
// Prints: [ 'foo', 'bar', Symbol(symbol) ]
function eventNames(): (string | symbol)[]
Retouren
(string | symbol)[]
Overgenomen van InternalClient.eventNames
getEventListeners(EventEmitter<DefaultEventMap> | EventTarget, string | symbol)
Retourneert een kopie van de matrix met listeners voor de gebeurtenis met de naam eventName
.
Voor EventEmitter
s gedraagt dit zich precies hetzelfde als het aanroepen .listeners
op de emitter.
Voor EventTarget
s is dit de enige manier om de gebeurtenislisteners voor het gebeurtenisdoel op te halen. Dit is handig voor foutopsporing en diagnostische doeleinden.
import { getEventListeners, EventEmitter } from 'node:events';
{
const ee = new EventEmitter();
const listener = () => console.log('Events are fun');
ee.on('foo', listener);
console.log(getEventListeners(ee, 'foo')); // [ [Function: listener] ]
}
{
const et = new EventTarget();
const listener = () => console.log('Events are fun');
et.addEventListener('foo', listener);
console.log(getEventListeners(et, 'foo')); // [ [Function: listener] ]
}
static function getEventListeners(emitter: EventEmitter<DefaultEventMap> | EventTarget, name: string | symbol): Function[]
Parameters
- emitter
-
EventEmitter<DefaultEventMap> | EventTarget
- name
-
string | symbol
Retouren
Function[]
Overgenomen van InternalClient.getEventListeners
getMaxListeners()
Retourneert de huidige maximale listenerwaarde voor de EventEmitter
die is ingesteld door emitter.setMaxListeners(n)
of standaard is ingesteld op defaultMaxListeners.
function getMaxListeners(): number
Retouren
number
Overgenomen van InternalClient.getMaxListeners
getMaxListeners(EventEmitter<DefaultEventMap> | EventTarget)
Retourneert het momenteel ingestelde maximumaantal listeners.
Voor EventEmitter
s gedraagt dit zich precies hetzelfde als het aanroepen .getMaxListeners
op de emitter.
Voor EventTarget
s is dit de enige manier om het maximum aantal gebeurtenislisteners voor het gebeurtenisdoel op te halen. Als het aantal gebeurtenis-handlers op één EventTarget de maximale set overschrijdt, wordt er een waarschuwing afgedrukt door EventTarget.
import { getMaxListeners, setMaxListeners, EventEmitter } from 'node:events';
{
const ee = new EventEmitter();
console.log(getMaxListeners(ee)); // 10
setMaxListeners(11, ee);
console.log(getMaxListeners(ee)); // 11
}
{
const et = new EventTarget();
console.log(getMaxListeners(et)); // 10
setMaxListeners(11, et);
console.log(getMaxListeners(et)); // 11
}
static function getMaxListeners(emitter: EventEmitter<DefaultEventMap> | EventTarget): number
Parameters
- emitter
-
EventEmitter<DefaultEventMap> | EventTarget
Retouren
number
Overgenomen van InternalClient.getMaxListeners
getTwin()
getTwin(Callback<Twin>)
function getTwin(done: Callback<Twin>)
Parameters
- done
-
Callback<Twin>
Overgenomen van InternalClient.getTwin
listenerCount(EventEmitter<DefaultEventMap>, string | symbol)
Waarschuwing
Deze API is nu afgeschaft.
Since v3.2.0 - Use listenerCount
instead.
Een klassemethode die het aantal listeners retourneert voor de opgegeven eventName
die is geregistreerd op de opgegeven emitter
.
import { EventEmitter, listenerCount } from 'node:events';
const myEmitter = new EventEmitter();
myEmitter.on('event', () => {});
myEmitter.on('event', () => {});
console.log(listenerCount(myEmitter, 'event'));
// Prints: 2
static function listenerCount(emitter: EventEmitter<DefaultEventMap>, eventName: string | symbol): number
Parameters
- emitter
-
EventEmitter<DefaultEventMap>
De emitter om een query uit te voeren
- eventName
-
string | symbol
De gebeurtenisnaam
Retouren
number
Overgenomen van InternalClient.listenerCount
listenerCount<K>(string | symbol, Function)
Retourneert het aantal listeners dat luistert naar de gebeurtenis met de naam eventName
.
Als listener
wordt opgegeven, wordt geretourneerd hoe vaak de listener wordt gevonden in de lijst met listeners van de gebeurtenis.
function listenerCount<K>(eventName: string | symbol, listener?: Function): number
Parameters
- eventName
-
string | symbol
De naam van de gebeurtenis die wordt beluisterd
- listener
-
Function
De functie gebeurtenis-handler
Retouren
number
Overgenomen van InternalClient.listenerCount
listeners<K>(string | symbol)
Retourneert een kopie van de matrix met listeners voor de gebeurtenis met de naam eventName
.
server.on('connection', (stream) => {
console.log('someone connected!');
});
console.log(util.inspect(server.listeners('connection')));
// Prints: [ [Function] ]
function listeners<K>(eventName: string | symbol): Function[]
Parameters
- eventName
-
string | symbol
Retouren
Function[]
Overgenomen van InternalClient.listeners
off<K>(string | symbol, (args: any[]) => void)
Alias voor emitter.removeListener()
.
function off<K>(eventName: string | symbol, listener: (args: any[]) => void): ModuleClient
Parameters
- eventName
-
string | symbol
- listener
-
(args: any[]) => void
Retouren
Overgenomen van InternalClient.off
on(EventEmitter<DefaultEventMap>, string, StaticEventEmitterOptions)
import { on, EventEmitter } from 'node:events';
import process from 'node:process';
const ee = new EventEmitter();
// Emit later on
process.nextTick(() => {
ee.emit('foo', 'bar');
ee.emit('foo', 42);
});
for await (const event of on(ee, 'foo')) {
// The execution of this inner block is synchronous and it
// processes one event at a time (even with await). Do not use
// if concurrent execution is required.
console.log(event); // prints ['bar'] [42]
}
// Unreachable here
Retourneert een AsyncIterator
die gebeurtenissen herhaalt eventName
. Er wordt gegooid als de EventEmitter
verzendt 'error'
. Alle listeners worden verwijderd wanneer de lus wordt afgesloten. De value
geretourneerd door elke iteratie is een matrix die bestaat uit de gegenereerde gebeurtenisargumenten.
Een AbortSignal
kan worden gebruikt om het wachten op gebeurtenissen te annuleren:
import { on, EventEmitter } from 'node:events';
import process from 'node:process';
const ac = new AbortController();
(async () => {
const ee = new EventEmitter();
// Emit later on
process.nextTick(() => {
ee.emit('foo', 'bar');
ee.emit('foo', 42);
});
for await (const event of on(ee, 'foo', { signal: ac.signal })) {
// The execution of this inner block is synchronous and it
// processes one event at a time (even with await). Do not use
// if concurrent execution is required.
console.log(event); // prints ['bar'] [42]
}
// Unreachable here
})();
process.nextTick(() => ac.abort());
static function on(emitter: EventEmitter<DefaultEventMap>, eventName: string, options?: StaticEventEmitterOptions): AsyncIterableIterator<any>
Parameters
- emitter
-
EventEmitter<DefaultEventMap>
- eventName
-
string
De naam van de gebeurtenis die wordt beluisterd
- options
-
StaticEventEmitterOptions
Retouren
AsyncIterableIterator<any>
Een AsyncIterator
die gebeurtenissen herhaalt eventName
die zijn verzonden door de emitter
Overgenomen van InternalClient.on
on<K>(string | symbol, (args: any[]) => void)
Hiermee voegt u de listener
functie toe aan het einde van de listeners-matrix voor de gebeurtenis met de naam eventName
. Er worden geen controles uitgevoerd om te zien of de listener
al is toegevoegd. Meerdere aanroepen die dezelfde combinatie van eventName
en listener
doorgeven, leiden ertoe dat de listener
meerdere keren wordt toegevoegd en aangeroepen.
server.on('connection', (stream) => {
console.log('someone connected!');
});
Retourneert een verwijzing naar de EventEmitter
, zodat aanroepen kunnen worden gekoppeld.
Gebeurtenislisteners worden standaard aangeroepen in de volgorde waarin ze worden toegevoegd. De emitter.prependListener()
methode kan worden gebruikt als alternatief om de gebeurtenislistener toe te voegen aan het begin van de listeners-matrix.
import { EventEmitter } from 'node:events';
const myEE = new EventEmitter();
myEE.on('foo', () => console.log('a'));
myEE.prependListener('foo', () => console.log('b'));
myEE.emit('foo');
// Prints:
// b
// a
function on<K>(eventName: string | symbol, listener: (args: any[]) => void): ModuleClient
Parameters
- eventName
-
string | symbol
De naam van de gebeurtenis.
- listener
-
(args: any[]) => void
De callback-functie
Retouren
Overgenomen van InternalClient.on
once(EventEmitter<DefaultEventMap>, string | symbol, StaticEventEmitterOptions)
Hiermee maakt u een Promise
die wordt uitgevoerd wanneer de EventEmitter
opgegeven gebeurtenis verzendt of die wordt geweigerd als de verzendt 'error'
tijdens het EventEmitter
wachten.
De Promise
wordt opgelost met een matrix van alle argumenten die naar de opgegeven gebeurtenis zijn verzonden.
Deze methode is opzettelijk algemeen en werkt met de EventTarget-interface van het webplatform, die geen speciale'error'
gebeurtenissemantiek heeft en niet naar de 'error'
gebeurtenis luistert.
import { once, EventEmitter } from 'node:events';
import process from 'node:process';
const ee = new EventEmitter();
process.nextTick(() => {
ee.emit('myevent', 42);
});
const [value] = await once(ee, 'myevent');
console.log(value);
const err = new Error('kaboom');
process.nextTick(() => {
ee.emit('error', err);
});
try {
await once(ee, 'myevent');
} catch (err) {
console.error('error happened', err);
}
De speciale verwerking van de 'error'
gebeurtenis wordt alleen gebruikt wanneer events.once()
wordt gebruikt om te wachten op een andere gebeurtenis. Als events.once()
wordt gebruikt om te wachten op de 'error'
gebeurtenis zelf, wordt deze behandeld als een ander soort gebeurtenis zonder speciale verwerking:
import { EventEmitter, once } from 'node:events';
const ee = new EventEmitter();
once(ee, 'error')
.then(([err]) => console.log('ok', err.message))
.catch((err) => console.error('error', err.message));
ee.emit('error', new Error('boom'));
// Prints: ok boom
Een AbortSignal
kan worden gebruikt om het wachten op de gebeurtenis te annuleren:
import { EventEmitter, once } from 'node:events';
const ee = new EventEmitter();
const ac = new AbortController();
async function foo(emitter, event, signal) {
try {
await once(emitter, event, { signal });
console.log('event emitted!');
} catch (error) {
if (error.name === 'AbortError') {
console.error('Waiting for the event was canceled!');
} else {
console.error('There was an error', error.message);
}
}
}
foo(ee, 'foo', ac.signal);
ac.abort(); // Abort waiting for the event
ee.emit('foo'); // Prints: Waiting for the event was canceled!
static function once(emitter: EventEmitter<DefaultEventMap>, eventName: string | symbol, options?: StaticEventEmitterOptions): Promise<any[]>
Parameters
- emitter
-
EventEmitter<DefaultEventMap>
- eventName
-
string | symbol
- options
-
StaticEventEmitterOptions
Retouren
Promise<any[]>
Overgenomen van InternalClient.once
once(EventTarget, string, StaticEventEmitterOptions)
static function once(emitter: EventTarget, eventName: string, options?: StaticEventEmitterOptions): Promise<any[]>
Parameters
- emitter
-
EventTarget
- eventName
-
string
- options
-
StaticEventEmitterOptions
Retouren
Promise<any[]>
Overgenomen van InternalClient.once
once<K>(string | symbol, (args: any[]) => void)
Voegt een eenmaligelistener
functie toe voor de gebeurtenis met de naam eventName
. De volgende keer eventName
dat deze listener wordt geactiveerd, wordt deze verwijderd en vervolgens aangeroepen.
server.once('connection', (stream) => {
console.log('Ah, we have our first user!');
});
Retourneert een verwijzing naar de EventEmitter
, zodat aanroepen kunnen worden gekoppeld.
Gebeurtenislisteners worden standaard aangeroepen in de volgorde waarin ze worden toegevoegd. De emitter.prependOnceListener()
methode kan worden gebruikt als alternatief om de gebeurtenislistener toe te voegen aan het begin van de listeners-matrix.
import { EventEmitter } from 'node:events';
const myEE = new EventEmitter();
myEE.once('foo', () => console.log('a'));
myEE.prependOnceListener('foo', () => console.log('b'));
myEE.emit('foo');
// Prints:
// b
// a
function once<K>(eventName: string | symbol, listener: (args: any[]) => void): ModuleClient
Parameters
- eventName
-
string | symbol
De naam van de gebeurtenis.
- listener
-
(args: any[]) => void
De callback-functie
Retouren
Overgenomen van InternalClient.once
open()
function open(): Promise<Connected>
Retouren
Promise<Connected>
Overgenomen van InternalClient.open
open(Callback<Connected>)
function open(openCallback: Callback<Connected>)
Parameters
- openCallback
-
Callback<Connected>
Overgenomen van InternalClient.open
prependListener<K>(string | symbol, (args: any[]) => void)
Hiermee voegt u de listener
functie toe aan het begin van de listeners-matrix voor de gebeurtenis met de naam eventName
. Er worden geen controles uitgevoerd om te zien of de listener
al is toegevoegd. Meerdere aanroepen die dezelfde combinatie van eventName
en listener
doorgeven, leiden ertoe dat de listener
meerdere keren wordt toegevoegd en aangeroepen.
server.prependListener('connection', (stream) => {
console.log('someone connected!');
});
Retourneert een verwijzing naar de EventEmitter
, zodat aanroepen kunnen worden gekoppeld.
function prependListener<K>(eventName: string | symbol, listener: (args: any[]) => void): ModuleClient
Parameters
- eventName
-
string | symbol
De naam van de gebeurtenis.
- listener
-
(args: any[]) => void
De callback-functie
Retouren
Overgenomen van InternalClient.prependListener
prependOnceListener<K>(string | symbol, (args: any[]) => void)
Hiermee voegt u een eenmaligelistener
functie toe voor de gebeurtenis met de naam eventName
aan het begin van de listeners-matrix. De volgende keer eventName
dat deze listener wordt geactiveerd, wordt deze verwijderd en vervolgens aangeroepen.
server.prependOnceListener('connection', (stream) => {
console.log('Ah, we have our first user!');
});
Retourneert een verwijzing naar de EventEmitter
, zodat aanroepen kunnen worden gekoppeld.
function prependOnceListener<K>(eventName: string | symbol, listener: (args: any[]) => void): ModuleClient
Parameters
- eventName
-
string | symbol
De naam van de gebeurtenis.
- listener
-
(args: any[]) => void
De callback-functie
Retouren
Overgenomen van InternalClient.prependOnceListener
rawListeners<K>(string | symbol)
Retourneert een kopie van de matrix met listeners voor de gebeurtenis met de naam eventName
, inclusief eventuele wrappers (zoals die zijn gemaakt door .once()
).
import { EventEmitter } from 'node:events';
const emitter = new EventEmitter();
emitter.once('log', () => console.log('log once'));
// Returns a new Array with a function `onceWrapper` which has a property
// `listener` which contains the original listener bound above
const listeners = emitter.rawListeners('log');
const logFnWrapper = listeners[0];
// Logs "log once" to the console and does not unbind the `once` event
logFnWrapper.listener();
// Logs "log once" to the console and removes the listener
logFnWrapper();
emitter.on('log', () => console.log('log persistently'));
// Will return a new Array with a single function bound by `.on()` above
const newListeners = emitter.rawListeners('log');
// Logs "log persistently" twice
newListeners[0]();
emitter.emit('log');
function rawListeners<K>(eventName: string | symbol): Function[]
Parameters
- eventName
-
string | symbol
Retouren
Function[]
Overgenomen van InternalClient.rawListeners
reject(Message)
function reject(message: Message): Promise<MessageRejected>
Parameters
- message
- Message
Retouren
Promise<MessageRejected>
Overgenomen van InternalClient.reject
reject(Message, Callback<MessageRejected>)
function reject(message: Message, rejectCallback: Callback<MessageRejected>)
Parameters
- message
- Message
- rejectCallback
-
Callback<MessageRejected>
Overgenomen van InternalClient.reject
removeAllListeners(string | symbol)
Hiermee verwijdert u alle listeners of die van de opgegeven eventName
.
Het is een slechte gewoonte om listeners te verwijderen die elders in de code zijn toegevoegd, met name wanneer het EventEmitter
exemplaar is gemaakt door een ander onderdeel of een andere module (bijvoorbeeld sockets of bestandsstromen).
Retourneert een verwijzing naar de EventEmitter
, zodat aanroepen kunnen worden gekoppeld.
function removeAllListeners(eventName?: string | symbol): ModuleClient
Parameters
- eventName
-
string | symbol
Retouren
Overgenomen van InternalClient.removeAllListeners
removeListener<K>(string | symbol, (args: any[]) => void)
Hiermee verwijdert u de opgegeven listener
uit de listenermatrix voor de gebeurtenis met de naam eventName
.
const callback = (stream) => {
console.log('someone connected!');
};
server.on('connection', callback);
// ...
server.removeListener('connection', callback);
removeListener()
verwijdert maximaal één exemplaar van een listener uit de listenermatrix. Als één listener meerdere keren is toegevoegd aan de listenermatrix voor de opgegeven eventName
, removeListener()
moet meerdere keren worden aangeroepen om elk exemplaar te verwijderen.
Zodra een gebeurtenis wordt verzonden, worden alle listeners die eraan zijn gekoppeld op het moment van verzenden in de volgorde aangeroepen. Dit betekent dat aanroepen removeListener()
of removeAllListeners()
aanroepen na het verzenden en voordat de uitvoering van de laatste listener is voltooid, niet worden verwijderd uitemit()
de actieve uitvoering. Volgende gebeurtenissen gedragen zich zoals verwacht.
import { EventEmitter } from 'node:events';
class MyEmitter extends EventEmitter {}
const myEmitter = new MyEmitter();
const callbackA = () => {
console.log('A');
myEmitter.removeListener('event', callbackB);
};
const callbackB = () => {
console.log('B');
};
myEmitter.on('event', callbackA);
myEmitter.on('event', callbackB);
// callbackA removes listener callbackB but it will still be called.
// Internal listener array at time of emit [callbackA, callbackB]
myEmitter.emit('event');
// Prints:
// A
// B
// callbackB is now removed.
// Internal listener array [callbackA]
myEmitter.emit('event');
// Prints:
// A
Omdat listeners worden beheerd met behulp van een interne matrix, verandert het aanroepen hiervan de positieindexen van elke listener die is geregistreerd nadat de listener is verwijderd. Dit heeft geen invloed op de volgorde waarin listeners worden aangeroepen, maar het betekent dat kopieën van de listenermatrix die door de emitter.listeners()
methode worden geretourneerd, opnieuw moeten worden gemaakt.
Wanneer één functie meerdere keren als handler is toegevoegd voor één gebeurtenis (zoals in het onderstaande voorbeeld), removeListener()
wordt het meest recent toegevoegde exemplaar verwijderd. In het voorbeeld is de once('ping')
listener verwijderd:
import { EventEmitter } from 'node:events';
const ee = new EventEmitter();
function pong() {
console.log('pong');
}
ee.on('ping', pong);
ee.once('ping', pong);
ee.removeListener('ping', pong);
ee.emit('ping');
ee.emit('ping');
Retourneert een verwijzing naar de EventEmitter
, zodat aanroepen kunnen worden gekoppeld.
function removeListener<K>(eventName: string | symbol, listener: (args: any[]) => void): ModuleClient
Parameters
- eventName
-
string | symbol
- listener
-
(args: any[]) => void
Retouren
Overgenomen van InternalClient.removeListener
sendEvent(Message)
function sendEvent(message: Message): Promise<MessageEnqueued>
Parameters
- message
- Message
Retouren
Promise<MessageEnqueued>
Overgenomen van InternalClient.sendEvent
sendEvent(Message, Callback<MessageEnqueued>)
function sendEvent(message: Message, sendEventCallback: Callback<MessageEnqueued>)
Parameters
- message
- Message
- sendEventCallback
-
Callback<MessageEnqueued>
Overgenomen van InternalClient.sendEvent
sendEventBatch(Message[])
function sendEventBatch(messages: Message[]): Promise<MessageEnqueued>
Parameters
- messages
-
Message[]
Retouren
Promise<MessageEnqueued>
Overgenomen van InternalClient.sendEventBatch
sendEventBatch(Message[], Callback<MessageEnqueued>)
function sendEventBatch(messages: Message[], sendEventBatchCallback: Callback<MessageEnqueued>)
Parameters
- messages
-
Message[]
- sendEventBatchCallback
-
Callback<MessageEnqueued>
Overgenomen van InternalClient.sendEventBatch
setMaxListeners(number)
EventEmitter
Standaard wordt met s een waarschuwing afgedrukt als er meer dan 10
listeners zijn toegevoegd voor een bepaalde gebeurtenis. Dit is een handige standaard die helpt bij het vinden van geheugenlekken. Met emitter.setMaxListeners()
de methode kan de limiet worden gewijzigd voor dit specifieke EventEmitter
exemplaar. De waarde kan worden ingesteld op Infinity
(of 0
) om een onbeperkt aantal listeners aan te geven.
Retourneert een verwijzing naar de EventEmitter
, zodat aanroepen kunnen worden gekoppeld.
function setMaxListeners(n: number): ModuleClient
Parameters
- n
-
number
Retouren
Overgenomen van InternalClient.setMaxListeners
setMaxListeners(number, (EventEmitter<DefaultEventMap> | EventTarget)[])
import { setMaxListeners, EventEmitter } from 'node:events';
const target = new EventTarget();
const emitter = new EventEmitter();
setMaxListeners(5, target, emitter);
static function setMaxListeners(n?: number, eventTargets: (EventEmitter<DefaultEventMap> | EventTarget)[])
Parameters
- n
-
number
Een niet-negatief getal. Het maximum aantal listeners per EventTarget
gebeurtenis.
- eventTargets
-
(EventEmitter<DefaultEventMap> | EventTarget)[]
Overgenomen van InternalClient.setMaxListeners
setRetryPolicy(RetryPolicy)
Hiermee stelt u het beleid voor opnieuw proberen dat door de client wordt gebruikt voor alle bewerkingen. De standaardwaarde is ExponentialBackoffWithJitter.
function setRetryPolicy(policy: RetryPolicy)
Parameters
- policy
-
RetryPolicy
{RetryPolicy} Het beleid voor opnieuw proberen dat moet worden gebruikt voor alle toekomstige bewerkingen.
Overgenomen van InternalClient.setRetryPolicy
setTransportOptions(any)
function setTransportOptions(options: any): Promise<TransportConfigured>
Parameters
- options
-
any
Retouren
Promise<TransportConfigured>
Overgenomen van InternalClient.setTransportOptions
setTransportOptions(any, Callback<TransportConfigured>)
function setTransportOptions(options: any, done: Callback<TransportConfigured>)
Parameters
- options
-
any
- done
-
Callback<TransportConfigured>
Overgenomen van InternalClient.setTransportOptions
updateSharedAccessSignature(string, Callback<SharedAccessSignatureUpdated>)
function updateSharedAccessSignature(sharedAccessSignature: string, updateSasCallback?: Callback<SharedAccessSignatureUpdated>)
Parameters
- sharedAccessSignature
-
string
- updateSasCallback
-
Callback<SharedAccessSignatureUpdated>
Overgenomen van InternalClient.updateSharedAccessSignature
[captureRejectionSymbol]<K>(Error, string | symbol, AnyRest)
function [captureRejectionSymbol]<K>(error: Error, event: string | symbol, args: AnyRest)
Parameters
- error
-
Error
- event
-
string | symbol
- args
-
AnyRest
Overgenomen van InternalClient.__@captureRejectionSymbol@138