Skip to content

Commit d62fc40

Browse files
committed
2 parents 99a0346 + b2362c2 commit d62fc40

File tree

3 files changed

+8
-5
lines changed

3 files changed

+8
-5
lines changed

package-lock.json

Lines changed: 3 additions & 3 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

package.json

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
{
22
"name": "nem2-sdk",
3-
"version": "0.9.3",
3+
"version": "0.9.4",
44
"description": "Reactive Nem2 sdk for typescript and javascript",
55
"scripts": {
66
"pretest": "npm run build",

src/infrastructure/Listener.ts

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -16,6 +16,7 @@
1616

1717
import 'rxjs/add/operator/filter';
1818
import 'rxjs/add/operator/map';
19+
import 'rxjs/add/operator/share';
1920
import {Observable} from 'rxjs/Observable';
2021
import {Subject} from 'rxjs/Subject';
2122
import * as WebSocket from 'ws';
@@ -197,7 +198,9 @@ export class Listener {
197198
*/
198199
public newBlock(): Observable<BlockInfo> {
199200
this.subscribeTo('block');
200-
return this.messageSubject.asObservable()
201+
return this.messageSubject
202+
.asObservable()
203+
.share()
201204
.filter((_) => _.channelName === ListenerChannelName.block)
202205
.filter((_) => _.message instanceof BlockInfo)
203206
.map((_) => _.message as BlockInfo);

0 commit comments

Comments
 (0)