loafer/ng
3
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

ing

Browse Source
This commit is contained in:
crusader 2018-07-02 16:14:17 +09:00
parent a34d69d9ec
commit 39dc1708e1
2 changed files with 14 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
projects/loafer/ng-rpc/package.json
View File

@ -1,6 +1,6 @@
{ {
"name": "@loafer/ng-rpc", "name": "@loafer/ng-rpc",
"version": "0.0.8", "version": "0.0.9",
"repository": { "repository": {
"type": "git", "type": "git",
"url": "https://git.loafle.net/loafer/ng.git" "url": "https://git.loafle.net/loafer/ng.git"

25
projects/loafer/ng-rpc/src/lib/client/rwc/websocket/RxWebsocketSubject.ts
View File

@ -12,17 +12,6 @@ const DEFAULT_RX_WEBSOCKET_CONFIG: RxWebsocketSubjectConfig<any> = {
url: '', url: '',
deserializer: (e: MessageEvent) => e, deserializer: (e: MessageEvent) => e,
serializer: (value: any) => value, serializer: (value: any) => value,
openObserver: {
next: (e: Event) => {
this._connectionObserver.next(true);
}
},
closeObserver: {
next: (e: CloseEvent) => {
this._socket = null;
this._connectionObserver.next(false);
}
},
reconnectInterval: 5000, reconnectInterval: 5000,
reconnectRetry: 10, reconnectRetry: 10,
}; };
@ -45,7 +34,19 @@ export class RxWebsocketSubject extends Subject<RPCMessage> {
distinctUntilChanged(), distinctUntilChanged(),
); );
this._wsSubjectConfig = this._config = { ...DEFAULT_RX_WEBSOCKET_CONFIG }; this._wsSubjectConfig = { ...DEFAULT_RX_WEBSOCKET_CONFIG };
this._wsSubjectConfig.openObserver = {
next: (e: Event) => {
this._connectionObserver.next(true);
}
};
this._wsSubjectConfig.closeObserver = {
next: (e: CloseEvent) => {
this._socket = null;
this._connectionObserver.next(false);
}
};
for (const key in _config) { for (const key in _config) {
if (_config.hasOwnProperty(key)) { if (_config.hasOwnProperty(key)) {
switch (key) { switch (key) {