ReactiveX/RxSwift
1
1
Fork 0
mirror of https://github.com/ReactiveX/RxSwift.git synced 2024-10-04 22:17:41 +03:00
Code Issues Projects Releases Wiki Activity

Rename elementAt(_:) to element(at:)

Browse Source
This commit is contained in:
freak4pc 2020-10-03 18:47:54 +03:00 committed by Shai Mishali
parent 4bd390ea93
commit 30d054cffc
2 changed files with 23 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
RxSwift/Observables/ElementAt.swift
View File

@ -7,6 +7,19 @@
//
extension ObservableType {
/**
Returns a sequence emitting only element _n_ emitted by an Observable
- seealso: [elementAt operator on reactivex.io](http://reactivex.io/documentation/operators/elementat.html)
- parameter index: The index of the required element (starting from 0).
- returns: An observable sequence that emits the desired element as its own sole emission.
*/
@available(*, deprecated, renamed: "element(at:)")
public func elementAt(_ index: Int)
-> Observable<Element> {
element(at: index)
}
/**
Returns a sequence emitting only element _n_ emitted by an Observable
@ -16,7 +29,7 @@ extension ObservableType {
- parameter index: The index of the required element (starting from 0).
- returns: An observable sequence that emits the desired element as its own sole emission.
*/
public func elementAt(_ index: Int)
public func element(at index: Int)
-> Observable<Element> {
ElementAt(source: self.asObservable(), index: index, throwOnEmpty: true)
}

18
Tests/RxSwiftTests/Observable+ElementAtTests.swift
View File

@ -42,7 +42,7 @@ extension ObservableElementAtTest {
])
let res = scheduler.start {
xs.elementAt(10)
xs.element(at: 10)
}
XCTAssertEqual(res.events, [
@ -71,7 +71,7 @@ extension ObservableElementAtTest {
])
let res = scheduler.start {
xs.elementAt(10)
xs.element(at: 10)
}
XCTAssertEqual(res.events, [
@ -110,7 +110,7 @@ extension ObservableElementAtTest {
])
let res = scheduler.start {
xs.elementAt(10)
xs.element(at: 10)
}
XCTAssertEqual(res.events, [
@ -138,7 +138,7 @@ extension ObservableElementAtTest {
])
let res = scheduler.start {
xs.elementAt(10)
xs.element(at: 10)
}
XCTAssertEqual(res.events, [
@ -177,7 +177,7 @@ extension ObservableElementAtTest {
])
let res = scheduler.start(disposed: 250) {
xs.elementAt(3)
xs.element(at: 3)
}
XCTAssertEqual(res.events, [])
@ -214,7 +214,7 @@ extension ObservableElementAtTest {
])
let res = scheduler.start(disposed: 400) {
xs.elementAt(3)
xs.element(at: 3)
}
XCTAssertEqual(res.events, [
@ -245,7 +245,7 @@ extension ObservableElementAtTest {
])
let res = scheduler.start {
xs.elementAt(0)
xs.element(at: 0)
}
XCTAssertEqual(res.events, [
@ -260,11 +260,11 @@ extension ObservableElementAtTest {
#if TRACE_RESOURCES
func testElementAtReleasesResourcesOnComplete() {
_ = Observable<Int>.just(1).elementAt(0).subscribe()
_ = Observable<Int>.just(1).element(at: 0).subscribe()
}
func testElementAtReleasesResourcesOnError() {
_ = Observable<Int>.error(testError).elementAt(1).subscribe()
_ = Observable<Int>.error(testError).element(at: 1).subscribe()
}
#endif
}