You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
{{ message }}
This repository was archived by the owner on Apr 20, 2018. It is now read-only.
<ahref="#rxreplaysubjectprototypedispose">#</a> [Ⓢ](https://github.com/Reactive-Extensions/RxJS/blob/master/src/core/subjects/ReplaySubject.js#L147-L150"View in source")
101
+
<ahref="#rxreplaysubjectprototypedispose">#</a> [Ⓢ](https://github.com/Reactive-Extensions/RxJS/blob/master/src/core/subjects/replaysubject.js#L130-L133"View in source")
<ahref="#rxreplaysubjectprototypehasobservers">#</a> [Ⓢ](https://github.com/Reactive-Extensions/RxJS/blob/master/src/core/subjects/ReplaySubject.js#L71-L73"View in source")
144
+
<ahref="#rxreplaysubjectprototypehasobservers">#</a> [Ⓢ](https://github.com/Reactive-Extensions/RxJS/blob/master/src/core/subjects/replaysubject.js#L61-L63"View in source")
145
145
146
146
Indicates whether the subject has observers subscribed to it.
Copy file name to clipboardExpand all lines: doc/designguidelines/readme.md
+6-6Lines changed: 6 additions & 6 deletions
Display the source diff
Display the rich diff
Original file line number
Diff line number
Diff line change
@@ -69,7 +69,7 @@ var dictionarySuggest = Rx.Observable.fromEvent(input, 'keyup')
69
69
.map(function () { returninput.value; })
70
70
.filter(function (text) { return!!text; })
71
71
.distinctUntilChanged()
72
-
.throttle(250)
72
+
.debounce(250)
73
73
.flatMapLatest(searchWikipedia)
74
74
.subscribe(
75
75
function (results) {
@@ -88,9 +88,9 @@ RxJS creates an observable sequence that models an existing `keyup` event on the
88
88
89
89
It then places several filters and projections on top of the event to make the event only fire if a unique value has come through. (The `keyup` event fires for every key stroke, so also if the user presses left or right arrow, moving the cursor but not changing the input text).
90
90
91
-
Next it makes sure the event only gets fired after 250 milliseconds of activity by using the `throttle` operator. (If the user is still typing characters, this saves a potentially expensive lookup that will be ignored immediately).
91
+
Next it makes sure the event only gets fired after 250 milliseconds of activity by using the `debounce` operator. (If the user is still typing characters, this saves a potentially expensive lookup that will be ignored immediately).
92
92
93
-
In traditionally written programs, this throttling would introduce separate callbacks through a timer. This timer could potentially throw exceptions (certain timers have a maximum amount of operations in flight).
93
+
In traditionally written programs, this debouncing would introduce separate callbacks through a timer. This timer could potentially throw exceptions (certain timers have a maximum amount of operations in flight).
94
94
95
95
Once the user input has been filtered down it is time to perform the dictionary lookup. As this is usually an expensive operation (e.g. a request to a server on the other side of the world), this operation is itself asynchronous as well.
96
96
@@ -268,12 +268,12 @@ A marble-diagram is a diagram that shows event occurring over time. A marble dia
By drawing the diagram we can see that we will need some kind of delay after the user input, before firing of another asynchronous call. The delay in this sample maps to the `throttle` operator. To create another observable sequence from an observable sequence we will use the `flatMap` or `selectMany` operator. This
271
+
By drawing the diagram we can see that we will need some kind of delay after the user input, before firing of another asynchronous call. The delay in this sample maps to the `debounce` operator. To create another observable sequence from an observable sequence we will use the `flatMap` or `selectMany` operator. This
0 commit comments