2486837735

Build Type

github

Committed by GitHub

Commit Message

<a href="https://github.com/Wiredcraft/nsq-strategies/commit/<a class=hub.com/Wiredcraft/nsq-strategies/commit/<a class="double-link" href="https://git"><a class=hub.com/Wiredcraft/nsq-strategies/commit/<a class="double-link" href="https://git"><a class=hub.com/Wiredcraft/nsq-strategies/commit/d9feadbd13af5d25cbaed7c47123739991740507">d9feadbd1<a href="https://github.com/Wiredcraft/nsq-strategies/commit/d9feadbd13af5d25cbaed7c47123739991740507">&quot;&gt;&amp;lt;a href=&amp;quot;https://github.com/Wiredcraft/nsq-strategies/commit/&lt;/a&gt;&lt;a class=&quot;double-link&quot; href=&quot;https://github.com/Wiredcraft/nsq-strategies/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/Wiredcraft/nsq-strategies/commit/d9feadbd13af5d25cbaed7c47123739991740507&quot;&gt;d9feadbd1&lt;/a&gt;&lt;a href=&quot;https://github.com/Wiredcraft/nsq-strategies/commit/d9feadbd13af5d25cbaed7c47123739991740507&quot;&gt;&amp;lt;a href=&amp;quot;https://github.com/Wiredcraft/nsq-strategies/commit/d9feadbd13af5d25cbaed7c471237399&lt;/a&gt;91740507&quot;>&quot;&gt;Merge &lt;/a&gt;&lt;a class=&quot;double-link&quot; href=&quot;https://github.com/Wiredcraft/nsq-strategies/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://github.com/Wiredcraft/nsq-strategies/commit/<a class="double-link" href="https://github.com/Wiredcraft/nsq-strategies/commit/1632a702036a75bd3c80a026b16bb9de5673be50">1632a7020</a><a href="https://github.com/Wiredcraft/nsq-strategies/commit/d9feadbd13af5d25cbaed7c47123739991740507">&amp;quot;&amp;gt;1632a7020&amp;lt;/a&amp;gt;&amp;quot;&amp;gt;1632a7020&amp;lt;/a&amp;gt;&amp;lt;a href=&amp;quot;https://github.com/Wiredcraft/nsq-strategies/commit/d9feadbd13af5d25cbaed7c47123739991740&lt;/a&gt;507&quot;&gt; into &lt;/a&gt;&lt;a class=&quot;double-link&quot; href=&quot;https://github.com/Wiredcraft/nsq-strategies/commit/<a class="double-link" href="https://github.com/Wiredcraft/nsq-strategies/commit/bede44d8d">bede44d8d">bede44d8d</a>

Pull Request Pull Request #51: feat: mocks for testing

Run Details

89 of 99 branches covered (89.9%)

95 of 95 new or added lines in 7 files covered. (100.0%)

297 of 311 relevant lines covered (95.5%)

11.0 hits per line

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

83.33

/src/mock/Consumer.ts

import { Observable, Subject } from 'rxjs';
import { Message } from 'nsqjs';
import { hook } from './index';

export class MockConsumer {
  private topic: string;
  private channel: string;

  connect() {
    // do nothing
  }

  consume(fn: (m: Message) => Promise<void> | void) {
    hook(this.topic, this.channel, fn);
  }

  toRx(event = 'message'): Observable<Message> {
    if (event !== 'message') {
      throw new Error('toRx with discarded event is not implemented in mock module');
    }
    return new Observable<Message>((subscriber) => {
      const s = new Subject<Message>();
      s.subscribe((msg) => subscriber.next(msg));
      hook(this.topic, this.channel, s);
    });
  }

  close() {
    // do nothing
  }
}

1	import { Observable, Subject } from 'rxjs';	3✔
2	import { Message } from 'nsqjs';
3	import { hook } from './index';	3✔
4
5	export class MockConsumer {	3✔
6	private topic: string;
7	private channel: string;
8
9	connect() {
10	// do nothing
11	}
12
13	consume(fn: (m: Message) => Promise<void> \| void) {
14	hook(this.topic, this.channel, fn);	6✔
15	}
16
17	toRx(event = 'message'): Observable<Message> {	3✔
18	if (event !== 'message') {	3!
19	throw new Error('toRx with discarded event is not implemented in mock module');	×
20	}
21	return new Observable<Message>((subscriber) => {	3✔
22	const s = new Subject<Message>();	3✔
23	s.subscribe((msg) => subscriber.next(msg));	3✔
24	hook(this.topic, this.channel, s);	3✔
25	});
26	}
27
28	close() {
29	// do nothing
30	}
31	}

Wiredcraft / nsq-strategies / 2486837735

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