georapbox / PubSub / 43

pending completion

Build # 43

Build Type

Pull #12

travis-ci-com

Committed by

web-flow

Commit Message

<a href="https://github.com/georapbox/PubSub/commit/<a class=hub.com/georapbox/PubSub/commit/<a class="double-link" href="https://git"><a class=hub.com/georapbox/PubSub/commit/<a class="double-link" href="https://git"><a class=hub.com/georapbox/PubSub/commit/<a class="double-link" href="https://git"><a class=hub.com/georapbox/PubSub/commit/d3ff3487ed80be7832402149053a9c8429b5ed29">d3ff3487e">&lt;a href=&quot;https://github.com/georapbox/PubSub/commit/</a><a class="double-link" href="https://github.com/georapbox/PubSub/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/georapbox/PubSub/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/georapbox/PubSub/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/georapbox/PubSub/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/georapbox/PubSub/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/georapbox/PubSub/commit/d3ff3487ed80be7832402149053a9c8429b5ed29">d3ff3487e</a><a href="https://github.com/georapbox/PubSub/commit/d3ff3487ed80be7832402149053a9c8429b5ed29">&quot;&gt;&amp;lt;a href=&amp;quot;https://github.com/georapbox/PubSub/commit/&lt;/a&gt;&lt;a class=&quot;double-link&quot; href=&quot;https://github.com/georapbox/PubSub/commit/&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://git&quot;&gt;&amp;lt;a class=&lt;/a&gt;hub.com/georapbox/PubSub/commit/&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://git&quot;&gt;&amp;lt;a class=&lt;/a&gt;hub.com/georapbox/PubSub/commit/&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://git&quot;&gt;&amp;lt;a class=&lt;/a&gt;hub.com/georapbox/PubSub/commit/&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://git&quot;&gt;&amp;lt;a class=&lt;/a&gt;hub.com/georapbox/PubSub/commit/&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://git&quot;&gt;&amp;lt;a class=&lt;/a&gt;hub.com/georapbox/PubSub/commit/d3ff3487ed80be7832402149053a9c8429b5ed29&quot;&gt;d3ff3487e&lt;/a&gt;&lt;a href=&quot;https://github.com/georapbox/PubSub/commit/d3ff3487ed80be7832402149053a9c8429b5ed29&quot;&gt... (continued)

Pull Request Pull Request #12: Update to v4

Run Details

36 of 44 branches covered (81.82%)

Branch coverage included in aggregate %.

50 of 50 new or added lines in 2 files covered. (100.0%)

89 of 90 relevant lines covered (98.89%)

7.67 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

93.62

/src/utils.js

export const forOwn = (obj, callback, thisArg) => {
  for (let key in obj) {
    if (Object.prototype.hasOwnProperty.call(obj, key)) {
      if (callback && callback.call(thisArg, obj[key], key, obj) === false) {
        return;
      }
    }
  }

  return obj;
};

export const alias = (fn, instance) => (...args) => instance[fn].apply(instance, args);

export const deliverTopic = (topic, data, instance) => {
  const topics = instance._pubsub_topics;
  const subscribers = topics[topic] ? [...topics[topic]] : [];

  for (let i = 0, len = subscribers.length; i < len; i += 1) {
    const token = subscribers[i].token;
    const currentSubscriber = subscribers[i];

    if (!instance._options.immediateExceptions) {
      try {
        currentSubscriber.callback(data, { name: topic, token: token });
      } catch (exception) {
        setTimeout(() => {
          throw exception;
        }, 0);
      }
    } else {
      currentSubscriber.callback(data, { name: topic, token: token });
    }

    // Unsubscribe from event based on tokenized reference,
    // if subscriber's property once is set to true.
    if (currentSubscriber.once === true) {
      instance.unsubscribe(token);
    }
  }
};

export const publishData = (topic, ...data) => data.length <= 1 ? data[0] : [...data];

export const publish = (instance, topic, data, sync) => {
  const topics = instance._pubsub_topics;

  if (!topics[topic]) {
    return false;
  }

  sync ? deliverTopic(topic, data, instance) : setTimeout(() => {
    deliverTopic(topic, data, instance);
  }, 0);

  return true;
};

1	export const forOwn = (obj, callback, thisArg) => {	1✔
2	for (let key in obj) {	4✔
3	if (Object.prototype.hasOwnProperty.call(obj, key)) {	4!
4	if (callback && callback.call(thisArg, obj[key], key, obj) === false) {	4✔
5	return;	1✔
6	}
7	}
8	}
9
10	return obj;	3✔
11	};
12
13	export const alias = (fn, instance) => (...args) => instance[fn].apply(instance, args);	2✔
14
15	export const deliverTopic = (topic, data, instance) => {	1✔
16	const topics = instance._pubsub_topics;	9✔
17	const subscribers = topics[topic] ? [...topics[topic]] : [];	9!
18
19	for (let i = 0, len = subscribers.length; i < len; i += 1) {	9✔
20	const token = subscribers[i].token;	11✔
21	const currentSubscriber = subscribers[i];	11✔
22
23	if (!instance._options.immediateExceptions) {	11✔
24	try {	10✔
25	currentSubscriber.callback(data, { name: topic, token: token });	10✔
26	} catch (exception) {
27	setTimeout(() => {	1✔
28	throw exception;	×
29	}, 0);
30	}
31	} else {
32	currentSubscriber.callback(data, { name: topic, token: token });	1✔
33	}
34
35	// Unsubscribe from event based on tokenized reference,
36	// if subscriber's property once is set to true.
37	if (currentSubscriber.once === true) {	10✔
38	instance.unsubscribe(token);	1✔
39	}
40	}
41	};
42
43	export const publishData = (topic, ...data) => data.length <= 1 ? data[0] : [...data];	10✔
44
45	export const publish = (instance, topic, data, sync) => {	1✔
46	const topics = instance._pubsub_topics;	10✔
47
48	if (!topics[topic]) {	10✔
49	return false;	1✔
50	}
51
52	sync ? deliverTopic(topic, data, instance) : setTimeout(() => {	9✔
53	deliverTopic(topic, data, instance);	3✔
54	}, 0);
55
56	return true;	8✔
57	};

georapbox / PubSub / 43

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous