Skip to content

Commit 94bc0d6

Browse files
author
Aleix Morgadas
committed
CHANGED Listener.newBlock is a shared observable
CHANGED version to 0.9.4
1 parent be669ab commit 94bc0d6

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';
@@ -186,7 +187,9 @@ export class Listener {
186187
*/
187188
public newBlock(): Observable<BlockInfo> {
188189
this.subscribeTo('block');
189-
return this.messageSubject.asObservable()
190+
return this.messageSubject
191+
.asObservable()
192+
.share()
190193
.filter((_) => _.channelName === ListenerChannelName.block)
191194
.filter((_) => _.message instanceof BlockInfo)
192195
.map((_) => _.message as BlockInfo);

0 commit comments

Comments
 (0)