node/test/parallel/test-diagnostics-channel-meta-channels.js at ae1f30e1424cd45502c51dd02e22f59ead904b63 · nodejs/node · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
'use strict';

const common = require('../common');
const dc = require('diagnostics_channel');
const assert = require('assert');

const testedChannel = dc.channel('test');
const testedSubscription = () => {};
const testedData = { foo: 'bar' };

{
  // should publish on meta channel for subscribe() on both inactive and active prototype
  const subscribeHandler = common.mustCall(({ channel, subscription }) => {
    assert.strictEqual(channel, testedChannel);
    assert.strictEqual(subscription, testedSubscription);
  }, 2); // called twice
  dc.subscribe('diagnostics_channel.subscribe', subscribeHandler);
  testedChannel.subscribe(testedSubscription); // inactive prototype
  testedChannel.subscribe(testedSubscription); // active prototype
  dc.unsubscribe('diagnostics_channel.subscribe', subscribeHandler);
}

{
  // should publish on meta channel for publish()
  const publishHandler = common.mustCall(({ channel, data }) => {
    assert.strictEqual(channel, testedChannel);
    assert.strictEqual(data, testedData);
  });
  dc.subscribe('diagnostics_channel.publish', publishHandler);
  testedChannel.publish(testedData);
  dc.unsubscribe('diagnostics_channel.publish', publishHandler);
}

{
  // should publish on meta channel for unsubscribe() on both inactive and active prototype
  const unsubscribeHandler = common.mustCall(({ channel, subscription }) => {
    assert.strictEqual(channel, testedChannel);
    assert.strictEqual(subscription, testedSubscription);
  }, 2); // called twice
  dc.subscribe('diagnostics_channel.unsubscribe', unsubscribeHandler);
  testedChannel.unsubscribe(testedSubscription); // active prototype
  testedChannel.unsubscribe(testedSubscription); // inactive prototype
}
// TODO: should it publish on inactive channels ?