|
3 | 3 | <head> |
4 | 4 | <meta charset="utf-8"> |
5 | 5 | <meta http-equiv="x-ua-compatible" content="ie=edge"> |
6 | | - <title>stompjs@7.0.0, rx-stomp@1.1.4</title> |
| 6 | + <title>stompjs@7.0.0, rx-stomp@2.0.0</title> |
7 | 7 | <meta name="description" content=""> |
8 | 8 | <meta name="viewport" content="width=device-width, initial-scale=1"> |
9 | 9 |
|
|
15 | 15 | <body> |
16 | 16 |
|
17 | 17 | <div class="navbar navbar-default navbar-fixed-top visible-xs"> |
18 | | - <a href="../" class="navbar-brand">stompjs@7.0.0, rx-stomp@1.1.4</a> |
| 18 | + <a href="../" class="navbar-brand">stompjs@7.0.0, rx-stomp@2.0.0</a> |
19 | 19 | <button type="button" class="btn btn-default btn-menu ion-ios-menu" id="btn-menu"></button> |
20 | 20 | </div> |
21 | 21 |
|
@@ -124,7 +124,7 @@ <h3 id="constructor">Constructor</h3> |
124 | 124 | </tr> |
125 | 125 | <tr> |
126 | 126 | <td class="col-md-4"> |
127 | | - <div class="io-line">Defined in <a href="" data-line="30" class="link-to-prism">consolidated/rx-stomp/src/rx-stomp-rpc.ts:30</a></div> |
| 127 | + <div class="io-line">Defined in <a href="" data-line="32" class="link-to-prism">consolidated/rx-stomp/src/rx-stomp-rpc.ts:32</a></div> |
128 | 128 | </td> |
129 | 129 | </tr> |
130 | 130 |
|
@@ -204,8 +204,8 @@ <h3 id="methods"> |
204 | 204 |
|
205 | 205 | <tr> |
206 | 206 | <td class="col-md-4"> |
207 | | - <div class="io-line">Defined in <a href="" data-line="56" |
208 | | - class="link-to-prism">consolidated/rx-stomp/src/rx-stomp-rpc.ts:56</a></div> |
| 207 | + <div class="io-line">Defined in <a href="" data-line="58" |
| 208 | + class="link-to-prism">consolidated/rx-stomp/src/rx-stomp-rpc.ts:58</a></div> |
209 | 209 | </td> |
210 | 210 | </tr> |
211 | 211 |
|
@@ -279,8 +279,8 @@ <h3 id="methods"> |
279 | 279 |
|
280 | 280 | <tr> |
281 | 281 | <td class="col-md-4"> |
282 | | - <div class="io-line">Defined in <a href="" data-line="67" |
283 | | - class="link-to-prism">consolidated/rx-stomp/src/rx-stomp-rpc.ts:67</a></div> |
| 282 | + <div class="io-line">Defined in <a href="" data-line="69" |
| 283 | + class="link-to-prism">consolidated/rx-stomp/src/rx-stomp-rpc.ts:69</a></div> |
284 | 284 | </td> |
285 | 285 | </tr> |
286 | 286 |
|
@@ -342,15 +342,17 @@ <h3 id="methods"> |
342 | 342 |
|
343 | 343 |
|
344 | 344 | <div class="tab-pane fade tab-source-code" id="c-source"> |
345 | | - <pre class="line-numbers compodoc-sourcecode"><code class="language-typescript">import { Observable, Observer, Subscription } from 'rxjs'; |
346 | | -import { filter, first } from 'rxjs/operators'; |
| 345 | + <pre class="line-numbers compodoc-sourcecode"><code class="language-typescript">import { filter, first, Observable, Observer, Subscription } from 'rxjs'; |
347 | 346 |
|
348 | | -import { UUID } from 'angular2-uuid'; |
| 347 | +import { v4 as uuid } from 'uuid'; |
349 | 348 |
|
350 | 349 | import { IMessage, IPublishParams, StompHeaders } from '@stomp/stompjs'; |
351 | 350 |
|
352 | | -import { RxStomp } from './rx-stomp'; |
353 | | -import { RxStompRPCConfig, setupReplyQueueFnType } from './rx-stomp-rpc-config'; |
| 351 | +import { RxStomp } from './rx-stomp.js'; |
| 352 | +import { |
| 353 | + RxStompRPCConfig, |
| 354 | + setupReplyQueueFnType, |
| 355 | +} from './rx-stomp-rpc-config.js'; |
354 | 356 |
|
355 | 357 | /** |
356 | 358 | * An implementation of Remote Procedure Call (RPC) using messaging. |
@@ -429,7 +431,7 @@ <h3 id="methods"> |
429 | 431 | return Observable.create((rpcObserver: Observer<IMessage>) => { |
430 | 432 | let defaultMessagesSubscription: Subscription; |
431 | 433 |
|
432 | | - const correlationId = headers['correlation-id'] || UUID.UUID(); |
| 434 | + const correlationId = headers['correlation-id'] || uuid(); |
433 | 435 |
|
434 | 436 | defaultMessagesSubscription = this._repliesObservable |
435 | 437 | .pipe( |
|
0 commit comments