Functions — github.com/RxJS-CN/RxJS-Docs-CN

hub / github.com/RxJS-CN/RxJS-Docs-CN / functions

Functions1,966 in github.com/RxJS-CN/RxJS-Docs-CN

⨍ Functions 1,966◇ Types & classes 707

↓ 4,554 callersMethodtoBe

(marbles: string, values?: any, errorValue?: any)

src/testing/TestScheduler.ts:104

↓ 2,525 callersFunctionexpectSubscriptions

(actualSubscriptionLogs: SubscriptionLog[])

spec/helpers/marble-testing.ts:34

↓ 2,453 callersFunctionit

(callback)

.markdown-doctest-setup.js:8

↓ 2,033 callersFunctionexpectObservable

(observable: Observable<any>, unsubscriptionMarbles: string = null)

spec/helpers/marble-testing.ts:26

↓ 1,826 callersFunctionhot

(marbles: string, values?: any, error?: any)

spec/helpers/marble-testing.ts:12

↓ 1,611 callersFunctioncold

(marbles: string, values?: any, error?: any)

spec/helpers/marble-testing.ts:19

↓ 1,007 callersMethodsubscribe

(observerOrNext?: PartialObserver<T> | ((value: T) => void), error?: (error: any) => void,

src/Observable.ts:12

↓ 598 callersMethodof

* 创建一个 Observable，它会依次发出由你提供的参数，最后发出完成通知。 * <span class="informal">发出你提供的参数，然后完成。 * </span> * * <img src="./img/of.png" width="100%"> *

src/observable/ArrayObservable.ts:58

↓ 435 callersMethodadd

(value: T)

src/util/Set.ts:8

↓ 195 callersMethodunsubscribe

()

src/Subscription.ts:15

↓ 150 callersMethodschedule

(work: (this: Action<T>, state?: T) => void, delay?: number, state?: T)

src/Scheduler.ts:6

↓ 140 callersMethodnext

(value: number)

spec/subjects/AsyncSubject-spec.ts:9

↓ 120 callersMethodfrom

(source: any)

spec/Observable-spec.ts:674

↓ 115 callersMethoderror

(err: any)

src/operator/catch.ts:99

↓ 111 callersMethodcall

(subscriber: Subscriber<R>, source: any)

src/Operator.ts:5

↓ 106 callersMethodforEach

(cb: (value: any, key: any) => void, thisArg?: any)

src/util/FastMap.ts:18

↓ 104 callersMethodcomplete

()

src/operator/repeat.ts:47

↓ 102 callersMethodnext

(value?: T)

spec/Observable-spec.ts:831

↓ 101 callersMethodnext

()

src/operator/zip.ts:242

↓ 95 callersMethodlift

(operator: Operator<T, R>)

src/observable/dom/WebSocketSubject.ts:108

↓ 83 callersMethoddo

* 给定一些 {@link Observer} 的回调函数，将当前 Notification 所表示的值正确的传递给相应的回调函数。 * @param {function(value: T): void} next Observer 的 `next` 回调函数。 * @param {f

src/Notification.ts:45

↓ 81 callersMethodcreate

* Subscriber 的静态工厂，给定了 Observer （潜在的部分）的定义。 * @param {function(x: ?T): void} [next] Observer 的 `next` 回调函数。 * @param {function(e: ?any): void} [

src/Subscriber.ts:27

↓ 72 callersMethodcomplete

()

spec/subjects/AsyncSubject-spec.ts:17

↓ 69 callersFunctiontime

(marbles: string)

spec/helpers/marble-testing.ts:41

↓ 65 callersMethodconnect

()

src/observable/ConnectableObservable.ts:34

↓ 52 callersMethodthen

(onFulfilled?, onRejected?)

spec/observables/from-promise-spec.ts:79

↓ 51 callersMethodcreateNext

* 使用给定的值创建类型为 `next` 的 Notification 实例的快捷方法。 * @param {T} value `next` 的值。 * @return {Notification<T>} 代表传入值的`next`型通知实例。

src/Notification.ts:98

↓ 51 callersFunctionsubscribeToResult

(outerSubscriber: OuterSubscriber<any, any>, result: ObservableInput<T>,

src/util/subscribeToResult.ts:17

↓ 46 callersMethodflush

()

src/testing/TestScheduler.ts:125

↓ 37 callersMethodparseMarbles

(marbles: string, values?: any, errorValue?: any,

src/testing/TestScheduler.ts:188

↓ 37 callersMethodrefCount

()

src/observable/ConnectableObservable.ts:51

↓ 32 callersMethodnext

()

src/observable/IteratorObservable.ts:110

↓ 32 callersMethodnow

()

src/Scheduler.ts:5

↓ 32 callersMethodset

(key: string, value: any)

src/util/FastMap.ts:9

↓ 31 callersFunctiontryCatch

(fn: T)

src/util/tryCatch.ts:14

↓ 29 callersMethodget

(url: string, headers?: Object)

src/observable/dom/AjaxObservable.ts:62

↓ 28 callersMethodaddEventListener

(name: string, handler: any)

spec/observables/dom/ajax-spec.ts:1007

↓ 28 callersMethodopen

()

spec/observables/dom/webSocket-spec.ts:682

↓ 25 callersMethoderror

(err: any)

spec/subjects/AsyncSubject-spec.ts:13

↓ 25 callersMethodparseMarblesAsSubscriptions

(marbles: string)

src/testing/TestScheduler.ts:139

↓ 24 callersMethodcreateComplete

* 创建类型为 `complete` 的 Notification 实例的快捷方法。 * @return {Notification<any>} 没有值的`complete`型的通知。

src/Notification.ts:118

↓ 24 callersMethodremove

* 从 Subscription 的内部列表中删除一个 Subscription。在该 Subscription 取消订阅的过程中 * 取消订阅。 * @param {Subscription} subscription 被移除的 subscription。 * @return {

src/Subscription.ts:181

↓ 20 callersMethodhas

(value: T)

src/util/Set.ts:9

↓ 18 callersMethodcreateError

* 使用给定的错误对象创建类型为 `error` 的 Notification 实例的快捷方法。 * @param {any} [err] `error` 错误。 * @return {Notification<T>} 代表传入错误的`error`型通知实例。

src/Notification.ts:110

↓ 16 callersMethodtriggerMessage

(data: any)

spec/observables/dom/webSocket-spec.ts:671

↓ 15 callersMethodnext

(value?: T)

src/Subject.ts:52

↓ 15 callersMethodrespondWith

(response: any, progressTimes?: number)

spec/observables/dom/ajax-spec.ts:1041

↓ 14 callersFunctiongetTimerSelector

(x)

spec/operators/debounce-spec.ts:15

↓ 13 callersMethoderror

(err: any)

src/Subject.ts:66

↓ 13 callersFunctionexpectObservableArray

(result, expected)

spec/operators/partition-spec.ts:15

↓ 12 callersFunctionisScheduler

(value: any)

src/util/isScheduler.ts:2

↓ 10 callersMethodcomplete

()

src/Subject.ts:82

↓ 10 callersMethodnext

(e: Event)

src/observable/dom/AjaxObservable.ts:208

↓ 9 callersFunction__export

(m)

doc/scripts/rxjs-spy.js:529

↓ 9 callersFunctionarrayRepeat

(value, times)

spec/operators/mergeMap-spec.ts:603

↓ 9 callersFunctionarrayRepeat

(value, times)

spec/operators/concatMap-spec.ts:525

↓ 9 callersMethodasObservable

()

src/Subject.ts:125

↓ 9 callersFunctionlowerCaseO

(...args)

spec/helpers/test-helper.ts:10

↓ 9 callersMethodobserve

* 将由 Notification 包装过的值传递给给定的 `observer`。 * @param {Observer} observer * @return

src/Notification.ts:27

↓ 8 callersMethodemit

(value: boolean)

src/operator/sequenceEqual.ts:123

↓ 8 callersFunctionsymbolIteratorPonyfill

(root: any)

src/symbol/iterator.ts:3

↓ 7 callersFunction_capitalize

(str)

doc/scripts/rxjs-spy.js:2027

↓ 7 callersMethod_unsubscribeAndRecycle

()

src/operator/repeatWhen.ts:98

↓ 7 callersMethodadd

* 添加一个 tear down 在该 Subscription 的 unsubscribe() 期间调用。 * * 如果清理是在已取消订阅的 subscription 时候添加的，那么它和 add 正在调用的引用是同一个， * 或者是 `Subscription.EMPTY`，

src/Subscription.ts:137

↓ 7 callersMethodmultiplex

(subMsg: () => any, unsubMsg: () => any, messageFilter: (value: T) => boolean)

src/observable/dom/WebSocketSubject.ts:123

↓ 7 callersMethodtriggerClose

(e: any)

spec/observables/dom/webSocket-spec.ts:666

↓ 6 callersMethod_resetState

()

src/observable/dom/WebSocketSubject.ts:114

↓ 6 callersMethodaccept

* 接受一个 Observer 或者它的回调函数，然后相应地调用 `observe` 或者 `do` 方法。 * @param {Observer|function(value: T): void} nextOrObserver Observer 或者 * `next` 回调函数。

src/Notification.ts:65

↓ 6 callersMethoddelete

(url: string, headers?: Object)

src/observable/dom/AjaxObservable.ts:66

↓ 6 callersFunctiongetKB

(size)

dangerfile.js:72

↓ 6 callersMethodgetValue

()

src/BehaviorSubject.ts:27

↓ 6 callersFunctionisPrime

(i)

spec/operators/filter-spec.ts:19

↓ 5 callersMethodaddFromSetImmediateArguments

(args: any[])

src/util/Immediate.ts:108

↓ 5 callersMethodclear

()

src/util/Set.ts:11

↓ 5 callersMethodclose

(code: any, reason: any)

spec/observables/dom/webSocket-spec.ts:687

↓ 5 callersFunctioncolorToGhostColor

(hex)

spec/helpers/tests2png/painter.js:26

↓ 5 callersFunctiongetSnapshotRef

(ref)

doc/scripts/rxjs-spy.js:868

↓ 5 callersFunctiongetTagValue

(tag, tagName)

tools/custom-esdoc-plugin.js:2

↓ 5 callersFunctionisFunction

(x: any)

src/util/isFunction.ts:1

↓ 5 callersFunctionisNumeric

(val: any)

src/util/isNumeric.ts:3

↓ 5 callersFunctionmeasureInclination

(startX, endX, angle)

spec/helpers/tests2png/painter.js:101

↓ 5 callersMethodon

()

spec/observables/fromEvent-spec.ts:290

↓ 5 callersMethodpartiallyApplied

(handler: any, ...args: any[])

src/util/Immediate.ts:92

↓ 5 callersMethodresultSelector

* @param {AjaxResponse} response * @return {T}

src/observable/dom/MiscJSDoc.ts:66

↓ 5 callersFunctiontoSubscriber

( nextOrObserver?: PartialObserver<T> | ((value: T) => void), error?: (error: any) => void, complete?: (

src/util/toSubscriber.ts:5

↓ 4 callersFunctionconcatStatic

(...observables: Array<ObservableInput<any> | IScheduler>)

src/operator/concat.ts:158

↓ 4 callersMethodexecute

(state: T, delay: number)

src/scheduler/QueueAction.ts:27

↓ 4 callersFunctionformatNumber

(n, fix)

perf/micro/index.js:44

↓ 4 callersFunctionisDate

(value: any)

src/util/isDate.ts:1

↓ 4 callersFunctionisNestedStreamData

(message)

spec/helpers/tests2png/painter.js:53

↓ 4 callersFunctionlogSubscription

(logger, name, subscription)

doc/scripts/rxjs-spy.js:1573

↓ 4 callersFunctionmapObject

(obj, fn)

spec/operators/groupBy-spec.ts:34

↓ 4 callersMethodopenContext

()

src/operator/bufferTime.ts:178

↓ 4 callersFunctionplugin

(plugin, name)

doc/scripts/rxjs-spy.js:1396

↓ 4 callersFunctionresultSelector

(x, i)

spec/operators/last-spec.ts:113

↓ 4 callersFunctionreverseString

(str)

spec/operators/groupBy-spec.ts:30

↓ 4 callersMethodsend

()

src/observable/dom/AjaxObservable.ts:216

↓ 4 callersFunctionsizeDiffBadge

(name, value)

dangerfile.js:88

↓ 4 callersMethodsubscribeToNextSource

()

src/operator/onErrorResumeNext.ts:141

↓ 4 callersMethodtoObservable

* 返回的 Observable 只传递代表当前 Notification 实例的通知。 * @return {any}

src/Notification.ts:77

next →1–100 of 1,966, ranked by callers