SharedAccessKeyAuthenticationProvider class

  • Başvuru
Paket:
azure-iot-device

Yalnızca bir AuthenticationProvider bağlantı dizesi ile oluşturulabilen ve daha sonra cihaz istemcisi tarafından kullanılan ve Azure IoT hub örneğiyle kimlik doğrulaması yapmak için taşınan bir nesne sağlar.

nesnesi, SharedAccessKeyAuthenticationProvider düzenli bir tempoda paylaşılan erişim imzası belirteçleri oluşturmayı üstlenir ve aktarımların newTokenAvailable kimlik bilgilerini Azure IoT hub örneğiyle yenilemesi ve bağlantıyı sürdürmesi için olayı yayar.

Extends

EventEmitter

Özellikler

type

Devralınan Özellikler

captureRejections

Değer: boole değeri

Tüm yeni EventEmitter nesnelerdeki varsayılan captureRejections seçeneği değiştirin.
captureRejectionSymbol

Değer: Symbol.for('nodejs.rejection')

Özel rejection handleryazma bölümüne bakın.
defaultMaxListeners

Varsayılan olarak, herhangi bir olay için en fazla 10 dinleyici kaydedilebilir. Bu sınır, yöntemi kullanılarak emitter.setMaxListeners(n) tek tek EventEmitter örnekler için değiştirilebilir. TümEventEmitter örneklerin varsayılan değerini events.defaultMaxListeners değiştirmek için özelliği kullanılabilir. Bu değer pozitif bir sayı değilse, bir RangeError oluşturulur.

ayarını events.defaultMaxListeners yaparken dikkatli olun çünkü değişiklik, değişiklik yapılmadan önce oluşturulanlar da dahil olmak üzere tümEventEmitter örnekleri etkiler. Ancak, çağrısının emitter.setMaxListeners(n) üzerinde önceliği events.defaultMaxListenersvardır.

Bu sabit bir sınır değildir. Örnek EventEmitter daha fazla dinleyici eklenmesine izin verir ancak stderr'a "olası EventEmitter bellek sızıntısı" algılandığını belirten bir izleme uyarısı verir. Herhangi bir tek EventEmitteriçin emitter.getMaxListeners() ve emitter.setMaxListeners() yöntemleri bu uyarıyı geçici olarak önlemek için kullanılabilir:

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));
});

Komut --trace-warnings satırı bayrağı, bu tür uyarıların yığın izlemesini görüntülemek için kullanılabilir.

Gösterilen uyarı ile process.on('warning') denetlenebilir ve ek , typeve özelliklerine sahip emitterolur; count sırasıyla olay verici örneğine, olayın adına ve eklenen dinleyici sayısına başvurur. Özelliği name olarak 'MaxListenersExceededWarning'ayarlanır.
errorMonitor

Bu simge yalnızca izleme 'error' olayları için bir dinleyici yüklemek için kullanılır. Bu simge kullanılarak yüklenen dinleyiciler, normal 'error' dinleyiciler çağrılmadan önce çağrılır.

Bu simgeyi kullanarak bir dinleyicinin yüklenmesi, bir 'error' olay yayımlandıktan sonra davranışı değiştirmez. Bu nedenle, normal 'error' dinleyici yüklü değilse işlem yine de kilitlenir.

Yöntemler

fromConnectionString(string, number, number)

bir bağlantı dizesi yeni SharedAccessKeyAuthenticationProvider bir oluşturur
getDeviceCredentials()
getDeviceCredentials(Callback<TransportConfig>)

Bu yöntem aktarımlar tarafından bir nesne biçiminde TransportConfig en güncel cihaz kimlik bilgilerini almak için kullanılır.
setTokenRenewalValues(number, number)

Bu yöntem, çağıranın kimlik doğrulaması yenilemesi için yeni değerler ayarlamasına olanak tanır.

Bu işlev zaman uyumlu olarak tamamlanır, ANCAK, eylemlerin zaman uyumsuz olarak gerçekleşmesine neden olur. Sağlayıcı zaten belirteç yenilemesi yapıyorsa (örneğin, bir ağ bağlantısı yapıldıysa) bu işlevin çağrılmış olması, neredeyse anında yeni bir yenilemenin gerçekleşmesine neden olur. Protokole bağlı olarak, bu bağlantının kesilmesine ve yeniden bağlanmasına neden olabilir. Ancak, yenilemeler şu anda gerçekleşmiyorsa, yeni değerleri daha sonra kullanmak üzere kaydederiz.
stop()

SAS belirtecini yenilemek için kullanılan zamanlayıcıyı durdurur.

Devralınan Yöntemler

addAbortListener(AbortSignal, (event: Event) => void)

Sağlanan signalüzerindeki olayı bir kez abort dinler.

İptal sinyallerinde olayı dinlemek abort güvenli değildir ve sinyale sahip başka bir üçüncü taraf çağırabileceğinden e.stopImmediatePropagation()kaynak sızıntılarına yol açabilir. Ne yazık ki Node.js web standardını ihlal edeceğinden bunu değiştiremez. Ayrıca, özgün API dinleyicileri kaldırmayı unutmayı kolaylaştırır.

Bu API, dinleyicinin çalışmasını engellemeyen olayı stopImmediatePropagation dinleyerek bu iki sorunu çözerek Node.js API'lerinde s'lerin güvenli bir şekilde kullanılmasına AbortSignalolanak tanır.

Aboneliğinin daha kolay kaldırılabilmesi için tek kullanımlık bir değer döndürür.

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]();
  }
}
addListener<K>(string | symbol, (args: any[]) => void)

diğer adı emitter.on(eventName, listener).
emit<K>(string | symbol, AnyRest)

adlı eventNameolay için kaydedilen dinleyicilerin her birini, kaydedildikleri sırayla zaman uyumlu olarak çağırır ve sağlanan bağımsız değişkenleri her birine geçirir.

Olayın dinleyicileri varsa, false aksi takdirde döndürürtrue.

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
eventNames()

Vericinin dinleyicileri kaydettiği olayları listeleyen bir dizi döndürür. Dizideki değerler dize veya Symboldizelerdir.

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) ]
getEventListeners(EventEmitter<DefaultEventMap> | EventTarget, string | symbol)

adlı eventNameolay için dinleyici dizisinin bir kopyasını döndürür.

s için EventEmitterbu, yayımlayıcıdaki çağrıyla .listeners tam olarak aynı şekilde davranır.

s için EventTarget, olay hedefi için olay dinleyicilerini edinmenin tek yolu budur. Bu, hata ayıklama ve tanılama amacıyla kullanışlıdır.

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] ]
}
getMaxListeners()

varsayılan Olarak veya varsayılan olarak defaultMaxListeners olarak ayarlanan emitter.setMaxListeners(n) geçerli en yüksek dinleyici değerini EventEmitter döndürür.
getMaxListeners(EventEmitter<DefaultEventMap> | EventTarget)

Şu anda ayarlanmış en fazla dinleyici miktarını döndürür.

s için EventEmitterbu, yayımlayıcıdaki çağrıyla .getMaxListeners tam olarak aynı şekilde davranır.

s için EventTarget, olay hedefi için maksimum olay dinleyicilerini almanın tek yolu budur. Tek bir EventTarget üzerindeki olay işleyicilerinin sayısı maksimum kümeyi aşarsa, EventTarget bir uyarı yazdırır.

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
}
listenerCount(EventEmitter<DefaultEventMap>, string | symbol)

Verilen eventNameemitterüzerinde kaydedilen için dinleyici sayısını döndüren bir sınıf yöntemi.

import { EventEmitter, listenerCount } from 'node:events';

const myEmitter = new EventEmitter();
myEmitter.on('event', () => {});
myEmitter.on('event', () => {});
console.log(listenerCount(myEmitter, 'event'));
// Prints: 2
listenerCount<K>(string | symbol, Function)

adlı eventNameolayı dinleyen dinleyicilerin sayısını döndürür. Sağlanırsa listener , dinleyicinin olay dinleyicileri listesinde kaç kez bulunduğunu döndürür.
listeners<K>(string | symbol)

adlı eventNameolay için dinleyici dizisinin bir kopyasını döndürür.

server.on('connection', (stream) => {
  console.log('someone connected!');
});
console.log(util.inspect(server.listeners('connection')));
// Prints: [ [Function] ]
off<K>(string | symbol, (args: any[]) => void)

diğer adı emitter.removeListener().
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

Olayları yineleyen eventName bir AsyncIterator döndürür. yayıyorsa EventEmitter'error'atacaktır. Döngüden çıkarken tüm dinleyicileri kaldırır. value Her yineleme tarafından döndürülen, yayılan olay bağımsız değişkenlerinden oluşan bir dizidir.

olayları AbortSignal beklemeyi iptal etmek için kullanılabilir:

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());
on<K>(string | symbol, (args: any[]) => void)

listener adlı eventNameolay için dinleyiciler dizisinin sonuna işlevini ekler. öğesinin zaten eklenip eklenmediğini listener görmek için denetim yapılmaz. aynı ve birleşimini eventNamelistener geçiren birden çok çağrı, birden çok kez eklenip çağrılmaya listener neden olur.

server.on('connection', (stream) => {
  console.log('someone connected!');
});

Çağrıların EventEmitterzincirlenebilmesi için öğesine bir başvuru döndürür.

Varsayılan olarak, olay dinleyicileri eklendikleri sırayla çağrılır. yöntemi, emitter.prependListener() olay dinleyicisini dinleyici dizisinin başına eklemek için alternatif olarak kullanılabilir.

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
once(EventEmitter<DefaultEventMap>, string | symbol, StaticEventEmitterOptions)

belirtilen olayı yaydığında yerine getiren veya beklerken yaydığında 'error'EventEmitter reddedilen bir Promise oluşturur.EventEmitter , Promise verilen olaya yayılan tüm bağımsız değişkenleri içeren bir diziyle çözümlenir.

Bu yöntem kasıtlı olarak geneldir ve özel'error' olay semantiği olmayan ve olayı dinlemeyen 'error' web platformu EventTarget arabirimiyle çalışır.

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);
}

Olayın özel işlemesi 'error' yalnızca başka bir olayı beklemek için kullanıldığında kullanılır events.once() . 'error' olayının kendisini beklemek için kullanılırsaevents.once(), özel işleme olmadan başka bir olay türü olarak kabul edilir:

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

olay AbortSignal beklenmeyi iptal etmek için kullanılabilir:

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!
once(EventTarget, string, StaticEventEmitterOptions)
once<K>(string | symbol, (args: any[]) => void)

adlı eventNameolay için tek seferliklistener bir işlev ekler. Bir sonraki tetiklendiğinde eventName , bu dinleyici kaldırılır ve sonra çağrılır.

server.once('connection', (stream) => {
  console.log('Ah, we have our first user!');
});

Çağrıların EventEmitterzincirlenebilmesi için öğesine bir başvuru döndürür.

Varsayılan olarak, olay dinleyicileri eklendikleri sırayla çağrılır. yöntemi, emitter.prependOnceListener() olay dinleyicisini dinleyici dizisinin başına eklemek için alternatif olarak kullanılabilir.

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
prependListener<K>(string | symbol, (args: any[]) => void)

listener adlı eventNameolay için dinleyiciler dizisinin başına işlevini ekler. öğesinin zaten eklenip eklenmediğini listener görmek için denetim yapılmaz. aynı ve birleşimini eventNamelistener geçiren birden çok çağrı, birden çok kez eklenip çağrılmaya listener neden olur.

server.prependListener('connection', (stream) => {
  console.log('someone connected!');
});

Çağrıların EventEmitterzincirlenebilmesi için öğesine bir başvuru döndürür.
prependOnceListener<K>(string | symbol, (args: any[]) => void)

Dinleyiciler dizisinin başına adlı eventName olay için tek seferliklistener bir işlev ekler. Bir sonraki tetiklendiğinde eventName , bu dinleyici kaldırılır ve sonra çağrılır.

server.prependOnceListener('connection', (stream) => {
  console.log('Ah, we have our first user!');
});

Çağrıların EventEmitterzincirlenebilmesi için öğesine bir başvuru döndürür.
rawListeners<K>(string | symbol)

adlı eventNameolay için dinleyici dizisinin, sarmalayıcılar da dahil olmak üzere bir kopyasını döndürür (örneğin, tarafından .once()oluşturulanlar).

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');
removeAllListeners(string | symbol)

Tüm dinleyicileri veya belirtilen eventNamedinleyicileri kaldırır.

Özellikle örnek başka bir bileşen veya modül (örneğin yuvalar veya dosya akışları) tarafından oluşturulduğunda kodun EventEmitter başka bir yerine eklenen dinleyicileri kaldırmak kötü bir uygulamadır.

Çağrıların EventEmitterzincirlenebilmesi için öğesine bir başvuru döndürür.
removeListener<K>(string | symbol, (args: any[]) => void)

adlı eventNameolay için dinleyici dizisinden belirtilen listener öğesini kaldırır.

const callback = (stream) => {
  console.log('someone connected!');
};
server.on('connection', callback);
// ...
server.removeListener('connection', callback);

removeListener() dinleyici dizisinden en fazla bir dinleyici örneğini kaldırır. Belirtilen eventNameremoveListener() için dinleyici dizisine birden çok kez tek bir dinleyici eklendiyse, her örneği kaldırmak için birden çok kez çağrılmalıdır.

Bir olay yayımlandıktan sonra, yayma sırasında olaya eklenen tüm dinleyiciler sırayla çağrılır. Bu, yadıktan sonra ve son dinleyici yürütmeyi bitirmeden önce yapılan veya removeListener()removeAllListeners() çağrılarının devam edendenemit() kaldırılmayacağını gösterir. Sonraki olaylar beklendiği gibi davranır.

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

Dinleyiciler bir iç dizi kullanılarak yönetildiğinden, bunu çağırmak dinleyici kaldırıldıktan sonra kaydedilen dinleyicilerin konum dizinlerini değiştirir. Bu, dinleyicilerin çağrılma sırasını etkilemez, ancak yöntem tarafından emitter.listeners() döndürülen dinleyici dizisinin tüm kopyalarının yeniden oluşturulması gerektiği anlamına gelir.

Tek bir işlev tek bir olay için birden çok kez işleyici olarak eklendiğinde (aşağıdaki örnekte olduğu gibi), removeListener() en son eklenen örneği kaldırır. Örnekte once('ping') dinleyici kaldırılır:

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');

Çağrıların EventEmitterzincirlenebilmesi için öğesine bir başvuru döndürür.
setMaxListeners(number)

Varsayılan olarak EventEmitter, belirli bir olay için birden fazla 10 dinleyici eklenirse s bir uyarı yazdırır. Bu, bellek sızıntılarını bulmaya yardımcı olan kullanışlı bir varsayılan değerdir. yöntemi, emitter.setMaxListeners() sınırın bu belirli EventEmitter örnek için değiştirilmesini sağlar. Sınırsız sayıda dinleyiciyi belirtmek için değer (veya 0) olarak ayarlanabilir Infinity .

Çağrıların EventEmitterzincirlenebilmesi için öğesine bir başvuru döndürür.
setMaxListeners(number, (EventEmitter<DefaultEventMap> | EventTarget)[]) 
import { setMaxListeners, EventEmitter } from 'node:events';

const target = new EventTarget();
const emitter = new EventEmitter();

setMaxListeners(5, target, emitter);
[captureRejectionSymbol]<K>(Error, string | symbol, AnyRest)

Özellik Ayrıntıları

type 

type: AuthenticationType

Özellik Değeri

AuthenticationType

Devralınan Özellik Detayları

captureRejections

Değer: boole değeri

Tüm yeni EventEmitter nesnelerdeki varsayılan captureRejections seçeneği değiştirin.

static captureRejections: boolean

Özellik Değeri

boolean

Devralınan EventEmitter.captureRejections

captureRejectionSymbol

Değer: Symbol.for('nodejs.rejection')

Özel rejection handleryazma bölümüne bakın.

static captureRejectionSymbol: typeof captureRejectionSymbol

Özellik Değeri

typeof captureRejectionSymbol

Devralınan EventEmitter.captureRejectionSymbol

defaultMaxListeners

Varsayılan olarak, herhangi bir olay için en fazla 10 dinleyici kaydedilebilir. Bu sınır, yöntemi kullanılarak emitter.setMaxListeners(n) tek tek EventEmitter örnekler için değiştirilebilir. TümEventEmitter örneklerin varsayılan değerini events.defaultMaxListeners değiştirmek için özelliği kullanılabilir. Bu değer pozitif bir sayı değilse, bir RangeError oluşturulur.

ayarını events.defaultMaxListeners yaparken dikkatli olun çünkü değişiklik, değişiklik yapılmadan önce oluşturulanlar da dahil olmak üzere tümEventEmitter örnekleri etkiler. Ancak, çağrısının emitter.setMaxListeners(n) üzerinde önceliği events.defaultMaxListenersvardır.

Bu sabit bir sınır değildir. Örnek EventEmitter daha fazla dinleyici eklenmesine izin verir ancak stderr'a "olası EventEmitter bellek sızıntısı" algılandığını belirten bir izleme uyarısı verir. Herhangi bir tek EventEmitteriçin emitter.getMaxListeners() ve emitter.setMaxListeners() yöntemleri bu uyarıyı geçici olarak önlemek için kullanılabilir:

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));
});

Komut --trace-warnings satırı bayrağı, bu tür uyarıların yığın izlemesini görüntülemek için kullanılabilir.

Gösterilen uyarı ile process.on('warning') denetlenebilir ve ek , typeve özelliklerine sahip emitterolur; count sırasıyla olay verici örneğine, olayın adına ve eklenen dinleyici sayısına başvurur. Özelliği name olarak 'MaxListenersExceededWarning'ayarlanır.

static defaultMaxListeners: number

Özellik Değeri

number

Devralınan EventEmitter.defaultMaxListeners

errorMonitor

Bu simge yalnızca izleme 'error' olayları için bir dinleyici yüklemek için kullanılır. Bu simge kullanılarak yüklenen dinleyiciler, normal 'error' dinleyiciler çağrılmadan önce çağrılır.

Bu simgeyi kullanarak bir dinleyicinin yüklenmesi, bir 'error' olay yayımlandıktan sonra davranışı değiştirmez. Bu nedenle, normal 'error' dinleyici yüklü değilse işlem yine de kilitlenir.

static errorMonitor: typeof errorMonitor

Özellik Değeri

typeof errorMonitor

Devralınan EventEmitter.errorMonitor

Yöntem Ayrıntıları

fromConnectionString(string, number, number)

bir bağlantı dizesi yeni SharedAccessKeyAuthenticationProvider bir oluşturur

static function fromConnectionString(connectionString: string, tokenValidTimeInSeconds?: number, tokenRenewalMarginInSeconds?: number): SharedAccessKeyAuthenticationProvider

Parametreler

connectionString

string

Cihaz bağlantı dizesi IoT hub'ı ile kimlik doğrulaması için gerekli parametreleri içerir.

tokenValidTimeInSeconds

number

[isteğe bağlı] Belirtecin geçerli olması gereken saniye sayısı.

tokenRenewalMarginInSeconds

number

[isteğe bağlı] Belirteci yenilemesi gereken geçerlilik süresinin SharedAccessKeyAuthenticationProvider bitiminde geçmesi gereken saniye sayısı.

Döndürülenler

SharedAccessKeyAuthenticationProvider

getDeviceCredentials() 

function getDeviceCredentials(): Promise<TransportConfig>

Döndürülenler

Promise<TransportConfig>

getDeviceCredentials(Callback<TransportConfig>)

Bu yöntem aktarımlar tarafından bir nesne biçiminde TransportConfig en güncel cihaz kimlik bilgilerini almak için kullanılır.

function getDeviceCredentials(callback?: Callback<TransportConfig>)

Parametreler

callback

Callback<TransportConfig>

ioT hub'ıyla kimlik doğrulaması yapmak için kullanılabilecek bir hata veya cihaz kimlik bilgileri kümesiyle çağrılacak isteğe bağlı işlev.

setTokenRenewalValues(number, number)

Bu yöntem, çağıranın kimlik doğrulaması yenilemesi için yeni değerler ayarlamasına olanak tanır.

Bu işlev zaman uyumlu olarak tamamlanır, ANCAK, eylemlerin zaman uyumsuz olarak gerçekleşmesine neden olur. Sağlayıcı zaten belirteç yenilemesi yapıyorsa (örneğin, bir ağ bağlantısı yapıldıysa) bu işlevin çağrılmış olması, neredeyse anında yeni bir yenilemenin gerçekleşmesine neden olur. Protokole bağlı olarak, bu bağlantının kesilmesine ve yeniden bağlanmasına neden olabilir. Ancak, yenilemeler şu anda gerçekleşmiyorsa, yeni değerleri daha sonra kullanmak üzere kaydederiz.

function setTokenRenewalValues(tokenValidTimeInSeconds: number, tokenRenewalMarginInSeconds: number)

Parametreler

tokenValidTimeInSeconds

number

Belirtecin geçerli olması gereken saniye sayısı.

tokenRenewalMarginInSeconds

number

Belirteci yenilemesi gereken geçerlilik süresinin SharedAccessKeyAuthenticationProvider bitiminde geçmesi gereken saniye sayısı.

stop()

SAS belirtecini yenilemek için kullanılan zamanlayıcıyı durdurur.

function stop()

Devralınan Yöntemin Ayrıntıları

addAbortListener(AbortSignal, (event: Event) => void)

Sağlanan signalüzerindeki olayı bir kez abort dinler.

İptal sinyallerinde olayı dinlemek abort güvenli değildir ve sinyale sahip başka bir üçüncü taraf çağırabileceğinden e.stopImmediatePropagation()kaynak sızıntılarına yol açabilir. Ne yazık ki Node.js web standardını ihlal edeceğinden bunu değiştiremez. Ayrıca, özgün API dinleyicileri kaldırmayı unutmayı kolaylaştırır.

Bu API, dinleyicinin çalışmasını engellemeyen olayı stopImmediatePropagation dinleyerek bu iki sorunu çözerek Node.js API'lerinde s'lerin güvenli bir şekilde kullanılmasına AbortSignalolanak tanır.

Aboneliğinin daha kolay kaldırılabilmesi için tek kullanımlık bir değer döndürür.

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

Parametreler

signal

AbortSignal

resource

(event: Event) => void

Döndürülenler

Disposable

Dinleyiciyi kaldıran abort atılabilir.

Devralınan EventEmitter.addAbortListener

addListener<K>(string | symbol, (args: any[]) => void)

diğer adı emitter.on(eventName, listener).

function addListener<K>(eventName: string | symbol, listener: (args: any[]) => void): SharedAccessKeyAuthenticationProvider

Parametreler

eventName

string | symbol

listener

(args: any[]) => void

Döndürülenler

SharedAccessKeyAuthenticationProvider

Devralınan EventEmitter.addListener

emit<K>(string | symbol, AnyRest)

adlı eventNameolay için kaydedilen dinleyicilerin her birini, kaydedildikleri sırayla zaman uyumlu olarak çağırır ve sağlanan bağımsız değişkenleri her birine geçirir.

Olayın dinleyicileri varsa, false aksi takdirde döndürürtrue.

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

Parametreler

eventName

string | symbol

args

AnyRest

Döndürülenler

boolean

Devralınan EventEmitter.emit

eventNames()

Vericinin dinleyicileri kaydettiği olayları listeleyen bir dizi döndürür. Dizideki değerler dize veya Symboldizelerdir.

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)[]

Döndürülenler

(string | symbol)[]

Devralınan EventEmitter.eventNames

getEventListeners(EventEmitter<DefaultEventMap> | EventTarget, string | symbol)

adlı eventNameolay için dinleyici dizisinin bir kopyasını döndürür.

s için EventEmitterbu, yayımlayıcıdaki çağrıyla .listeners tam olarak aynı şekilde davranır.

s için EventTarget, olay hedefi için olay dinleyicilerini edinmenin tek yolu budur. Bu, hata ayıklama ve tanılama amacıyla kullanışlıdır.

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[]

Parametreler

emitter

EventEmitter<DefaultEventMap> | EventTarget

name

string | symbol

Döndürülenler

Function[]

Devralınan EventEmitter.getEventListeners

getMaxListeners()

varsayılan Olarak veya varsayılan olarak defaultMaxListeners olarak ayarlanan emitter.setMaxListeners(n) geçerli en yüksek dinleyici değerini EventEmitter döndürür.

function getMaxListeners(): number

Döndürülenler

number

Devralınan EventEmitter.getMaxListeners

getMaxListeners(EventEmitter<DefaultEventMap> | EventTarget)

Şu anda ayarlanmış en fazla dinleyici miktarını döndürür.

s için EventEmitterbu, yayımlayıcıdaki çağrıyla .getMaxListeners tam olarak aynı şekilde davranır.

s için EventTarget, olay hedefi için maksimum olay dinleyicilerini almanın tek yolu budur. Tek bir EventTarget üzerindeki olay işleyicilerinin sayısı maksimum kümeyi aşarsa, EventTarget bir uyarı yazdırır.

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

Parametreler

emitter

EventEmitter<DefaultEventMap> | EventTarget

Döndürülenler

number

Devralınan EventEmitter.getMaxListeners

listenerCount(EventEmitter<DefaultEventMap>, string | symbol)

Uyarı

Bu API artık kullanım dışıdır.

Since v3.2.0 - Use listenerCount instead.

Verilen eventNameemitterüzerinde kaydedilen için dinleyici sayısını döndüren bir sınıf yöntemi.

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

Parametreler

emitter

EventEmitter<DefaultEventMap>

Sorguya yayımlayıcı

eventName

string | symbol

Olay adı

Döndürülenler

number

Devralınan EventEmitter.listenerCount

listenerCount<K>(string | symbol, Function)

adlı eventNameolayı dinleyen dinleyicilerin sayısını döndürür. Sağlanırsa listener , dinleyicinin olay dinleyicileri listesinde kaç kez bulunduğunu döndürür.

function listenerCount<K>(eventName: string | symbol, listener?: Function): number

Parametreler

eventName

string | symbol

Dinlenen olayın adı

listener

Function

Olay işleyici işlevi

Döndürülenler

number

Devralınan EventEmitter.listenerCount

listeners<K>(string | symbol)

adlı eventNameolay için dinleyici dizisinin bir kopyasını döndürür.

server.on('connection', (stream) => {
  console.log('someone connected!');
});
console.log(util.inspect(server.listeners('connection')));
// Prints: [ [Function] ]

function listeners<K>(eventName: string | symbol): Function[]

Parametreler

eventName

string | symbol

Döndürülenler

Function[]

Devralınan EventEmitter.listeners

off<K>(string | symbol, (args: any[]) => void)

diğer adı emitter.removeListener().

function off<K>(eventName: string | symbol, listener: (args: any[]) => void): SharedAccessKeyAuthenticationProvider

Parametreler

eventName

string | symbol

listener

(args: any[]) => void

Döndürülenler

SharedAccessKeyAuthenticationProvider

Devralınan EventEmitter.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

Olayları yineleyen eventName bir AsyncIterator döndürür. yayıyorsa EventEmitter'error'atacaktır. Döngüden çıkarken tüm dinleyicileri kaldırır. value Her yineleme tarafından döndürülen, yayılan olay bağımsız değişkenlerinden oluşan bir dizidir.

olayları AbortSignal beklemeyi iptal etmek için kullanılabilir:

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>

Parametreler

emitter

EventEmitter<DefaultEventMap>

eventName

string

Dinlenen olayın adı

options

StaticEventEmitterOptions

Döndürülenler

AsyncIterableIterator<any>

AsyncIterator Tarafından yayılan olayları yineleyen eventNameemitter

Devralınan EventEmitter.on

on<K>(string | symbol, (args: any[]) => void)

listener adlı eventNameolay için dinleyiciler dizisinin sonuna işlevini ekler. öğesinin zaten eklenip eklenmediğini listener görmek için denetim yapılmaz. aynı ve birleşimini eventNamelistener geçiren birden çok çağrı, birden çok kez eklenip çağrılmaya listener neden olur.

server.on('connection', (stream) => {
  console.log('someone connected!');
});

Çağrıların EventEmitterzincirlenebilmesi için öğesine bir başvuru döndürür.

Varsayılan olarak, olay dinleyicileri eklendikleri sırayla çağrılır. yöntemi, emitter.prependListener() olay dinleyicisini dinleyici dizisinin başına eklemek için alternatif olarak kullanılabilir.

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): SharedAccessKeyAuthenticationProvider

Parametreler

eventName

string | symbol

Olayın adı.

listener

(args: any[]) => void

Geri çağırma işlevi

Döndürülenler

SharedAccessKeyAuthenticationProvider

Devralınan EventEmitter.on

once(EventEmitter<DefaultEventMap>, string | symbol, StaticEventEmitterOptions)

belirtilen olayı yaydığında yerine getiren veya beklerken yaydığında 'error'EventEmitter reddedilen bir Promise oluşturur.EventEmitter , Promise verilen olaya yayılan tüm bağımsız değişkenleri içeren bir diziyle çözümlenir.

Bu yöntem kasıtlı olarak geneldir ve özel'error' olay semantiği olmayan ve olayı dinlemeyen 'error' web platformu EventTarget arabirimiyle çalışır.

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);
}

Olayın özel işlemesi 'error' yalnızca başka bir olayı beklemek için kullanıldığında kullanılır events.once() . 'error' olayının kendisini beklemek için kullanılırsaevents.once(), özel işleme olmadan başka bir olay türü olarak kabul edilir:

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

olay AbortSignal beklenmeyi iptal etmek için kullanılabilir:

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[]>

Parametreler

emitter

EventEmitter<DefaultEventMap>

eventName

string | symbol

options

StaticEventEmitterOptions

Döndürülenler

Promise<any[]>

Devralınan EventEmitter.once

once(EventTarget, string, StaticEventEmitterOptions) 

static function once(emitter: EventTarget, eventName: string, options?: StaticEventEmitterOptions): Promise<any[]>

Parametreler

emitter

EventTarget

eventName

string

options

StaticEventEmitterOptions

Döndürülenler

Promise<any[]>

Devralınan EventEmitter.once

once<K>(string | symbol, (args: any[]) => void)

adlı eventNameolay için tek seferliklistener bir işlev ekler. Bir sonraki tetiklendiğinde eventName , bu dinleyici kaldırılır ve sonra çağrılır.

server.once('connection', (stream) => {
  console.log('Ah, we have our first user!');
});

Çağrıların EventEmitterzincirlenebilmesi için öğesine bir başvuru döndürür.

Varsayılan olarak, olay dinleyicileri eklendikleri sırayla çağrılır. yöntemi, emitter.prependOnceListener() olay dinleyicisini dinleyici dizisinin başına eklemek için alternatif olarak kullanılabilir.

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): SharedAccessKeyAuthenticationProvider

Parametreler

eventName

string | symbol

Olayın adı.

listener

(args: any[]) => void

Geri çağırma işlevi

Döndürülenler

SharedAccessKeyAuthenticationProvider

Devralınan EventEmitter.once

prependListener<K>(string | symbol, (args: any[]) => void)

listener adlı eventNameolay için dinleyiciler dizisinin başına işlevini ekler. öğesinin zaten eklenip eklenmediğini listener görmek için denetim yapılmaz. aynı ve birleşimini eventNamelistener geçiren birden çok çağrı, birden çok kez eklenip çağrılmaya listener neden olur.

server.prependListener('connection', (stream) => {
  console.log('someone connected!');
});

Çağrıların EventEmitterzincirlenebilmesi için öğesine bir başvuru döndürür.

function prependListener<K>(eventName: string | symbol, listener: (args: any[]) => void): SharedAccessKeyAuthenticationProvider

Parametreler

eventName

string | symbol

Olayın adı.

listener

(args: any[]) => void

Geri çağırma işlevi

Döndürülenler

SharedAccessKeyAuthenticationProvider

Devralınan EventEmitter.prependListener

prependOnceListener<K>(string | symbol, (args: any[]) => void)

Dinleyiciler dizisinin başına adlı eventName olay için tek seferliklistener bir işlev ekler. Bir sonraki tetiklendiğinde eventName , bu dinleyici kaldırılır ve sonra çağrılır.

server.prependOnceListener('connection', (stream) => {
  console.log('Ah, we have our first user!');
});

Çağrıların EventEmitterzincirlenebilmesi için öğesine bir başvuru döndürür.

function prependOnceListener<K>(eventName: string | symbol, listener: (args: any[]) => void): SharedAccessKeyAuthenticationProvider

Parametreler

eventName

string | symbol

Olayın adı.

listener

(args: any[]) => void

Geri çağırma işlevi

Döndürülenler

SharedAccessKeyAuthenticationProvider

Devralınan EventEmitter.prependOnceListener

rawListeners<K>(string | symbol)

adlı eventNameolay için dinleyici dizisinin, sarmalayıcılar da dahil olmak üzere bir kopyasını döndürür (örneğin, tarafından .once()oluşturulanlar).

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[]

Parametreler

eventName

string | symbol

Döndürülenler

Function[]

Devralınan EventEmitter.rawListeners

removeAllListeners(string | symbol)

Tüm dinleyicileri veya belirtilen eventNamedinleyicileri kaldırır.

Özellikle örnek başka bir bileşen veya modül (örneğin yuvalar veya dosya akışları) tarafından oluşturulduğunda kodun EventEmitter başka bir yerine eklenen dinleyicileri kaldırmak kötü bir uygulamadır.

Çağrıların EventEmitterzincirlenebilmesi için öğesine bir başvuru döndürür.

function removeAllListeners(eventName?: string | symbol): SharedAccessKeyAuthenticationProvider

Parametreler

eventName

string | symbol

Döndürülenler

SharedAccessKeyAuthenticationProvider

Devralınan EventEmitter.removeAllListeners

removeListener<K>(string | symbol, (args: any[]) => void)

adlı eventNameolay için dinleyici dizisinden belirtilen listener öğesini kaldırır.

const callback = (stream) => {
  console.log('someone connected!');
};
server.on('connection', callback);
// ...
server.removeListener('connection', callback);

removeListener() dinleyici dizisinden en fazla bir dinleyici örneğini kaldırır. Belirtilen eventNameremoveListener() için dinleyici dizisine birden çok kez tek bir dinleyici eklendiyse, her örneği kaldırmak için birden çok kez çağrılmalıdır.

Bir olay yayımlandıktan sonra, yayma sırasında olaya eklenen tüm dinleyiciler sırayla çağrılır. Bu, yadıktan sonra ve son dinleyici yürütmeyi bitirmeden önce yapılan veya removeListener()removeAllListeners() çağrılarının devam edendenemit() kaldırılmayacağını gösterir. Sonraki olaylar beklendiği gibi davranır.

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

Dinleyiciler bir iç dizi kullanılarak yönetildiğinden, bunu çağırmak dinleyici kaldırıldıktan sonra kaydedilen dinleyicilerin konum dizinlerini değiştirir. Bu, dinleyicilerin çağrılma sırasını etkilemez, ancak yöntem tarafından emitter.listeners() döndürülen dinleyici dizisinin tüm kopyalarının yeniden oluşturulması gerektiği anlamına gelir.

Tek bir işlev tek bir olay için birden çok kez işleyici olarak eklendiğinde (aşağıdaki örnekte olduğu gibi), removeListener() en son eklenen örneği kaldırır. Örnekte once('ping') dinleyici kaldırılır:

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');

Çağrıların EventEmitterzincirlenebilmesi için öğesine bir başvuru döndürür.

function removeListener<K>(eventName: string | symbol, listener: (args: any[]) => void): SharedAccessKeyAuthenticationProvider

Parametreler

eventName

string | symbol

listener

(args: any[]) => void

Döndürülenler

SharedAccessKeyAuthenticationProvider

Devralınan EventEmitter.removeListener

setMaxListeners(number)

Varsayılan olarak EventEmitter, belirli bir olay için birden fazla 10 dinleyici eklenirse s bir uyarı yazdırır. Bu, bellek sızıntılarını bulmaya yardımcı olan kullanışlı bir varsayılan değerdir. yöntemi, emitter.setMaxListeners() sınırın bu belirli EventEmitter örnek için değiştirilmesini sağlar. Sınırsız sayıda dinleyiciyi belirtmek için değer (veya 0) olarak ayarlanabilir Infinity .

Çağrıların EventEmitterzincirlenebilmesi için öğesine bir başvuru döndürür.

function setMaxListeners(n: number): SharedAccessKeyAuthenticationProvider

Parametreler

n

number

Döndürülenler

SharedAccessKeyAuthenticationProvider

Devralınan EventEmitter.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)[])

Parametreler

n

number

Negatif olmayan bir sayı. Olay başına EventTarget en fazla dinleyici sayısı.

eventTargets

(EventEmitter<DefaultEventMap> | EventTarget)[]

Devralınan EventEmitter.setMaxListeners

[captureRejectionSymbol]<K>(Error, string | symbol, AnyRest) 

function [captureRejectionSymbol]<K>(error: Error, event: string | symbol, args: AnyRest)

Parametreler

error

Error

event

string | symbol

args

AnyRest

Devralınan EventEmitter.__@captureRejectionSymbol@138