TouchInstinct
/
RxSwift
303
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Fixes `@warn_unused_result(message: "http://git.io/rxs.ud")` warnings.

This commit is contained in:
Krunoslav Zaher 2016-07-08 00:04:44 +02:00
parent 6770c8a4c0
commit e2edffc39d
34 changed files with 201 additions and 201 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
Rx.xcodeproj/project.pbxproj
View File

@ -1444,7 +1444,7 @@
C8093C641B8A72BE0088E94D /* Event.swift */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.swift; path = Event.swift; sourceTree = "<group>"; };
C8093C651B8A72BE0088E94D /* ImmediateSchedulerType.swift */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.swift; path = ImmediateSchedulerType.swift; sourceTree = "<group>"; };
C8093C661B8A72BE0088E94D /* Info.plist */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = text.plist.xml; path = Info.plist; sourceTree = "<group>"; };
C8093C671B8A72BE0088E94D /* Observable+Extensions.swift */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.swift; path = "Observable+Extensions.swift"; sourceTree = "<group>"; };
C8093C671B8A72BE0088E94D /* Observable+Extensions.swift */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.swift; lineEnding = 0; path = "Observable+Extensions.swift"; sourceTree = "<group>"; xcLanguageSpecificationIdentifier = xcode.lang.swift; };
C8093C681B8A72BE0088E94D /* Observable.swift */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.swift; path = Observable.swift; sourceTree = "<group>"; };
C8093C6B1B8A72BE0088E94D /* Amb.swift */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.swift; path = Amb.swift; sourceTree = "<group>"; };
C8093C6E1B8A72BE0088E94D /* Catch.swift */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.swift; path = Catch.swift; sourceTree = "<group>"; };
@ -1539,7 +1539,7 @@
C8093ECB1B8A732E0088E94D /* RxCocoa.h */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.c.h; path = RxCocoa.h; sourceTree = "<group>"; };
C8093F581B8A73A20088E94D /* ObservableConvertibleType+Blocking.swift */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.swift; path = "ObservableConvertibleType+Blocking.swift"; sourceTree = "<group>"; xcLanguageSpecificationIdentifier = xcode.lang.swift; };
C8093F591B8A73A20088E94D /* README.md */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = net.daringfireball.markdown; path = README.md; sourceTree = "<group>"; };
C80D338E1B91EF9E0014629D /* Observable+Bind.swift */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.swift; path = "Observable+Bind.swift"; sourceTree = "<group>"; };
C80D338E1B91EF9E0014629D /* Observable+Bind.swift */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.swift; lineEnding = 0; path = "Observable+Bind.swift"; sourceTree = "<group>"; xcLanguageSpecificationIdentifier = xcode.lang.swift; };
C80D33931B922FB00014629D /* ControlEvent.swift */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.swift; path = ControlEvent.swift; sourceTree = "<group>"; };
C80D33941B922FB00014629D /* ControlProperty.swift */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.swift; lineEnding = 0; path = ControlProperty.swift; sourceTree = "<group>"; xcLanguageSpecificationIdentifier = xcode.lang.swift; };
C80D342D1B9245A40014629D /* CombineLatest+CollectionType.swift */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.swift; lineEnding = 0; path = "CombineLatest+CollectionType.swift"; sourceTree = "<group>"; xcLanguageSpecificationIdentifier = xcode.lang.swift; };

2
RxBlocking/ObservableConvertibleType+Blocking.swift
View File

@ -17,7 +17,7 @@ extension ObservableConvertibleType {
- returns: `BlockingObservable` version of `self`
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func toBlocking() -> BlockingObservable<E> {
return BlockingObservable(source: self.asObservable())
}

4
RxCocoa/Common/CocoaUnits/ControlEvent.swift
View File

@ -71,7 +71,7 @@ public struct ControlEvent<PropertyType> : ControlEventType {
/**
- returns: `Observable` interface.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func asObservable() -> Observable<E> {
return _events
}
@ -79,7 +79,7 @@ public struct ControlEvent<PropertyType> : ControlEventType {
/**
- returns: `ControlEvent` interface.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func asControlEvent() -> ControlEvent<E> {
return self
}

4
RxCocoa/Common/CocoaUnits/ControlProperty.swift
View File

@ -77,7 +77,7 @@ public struct ControlProperty<PropertyType> : ControlPropertyType {
/**
- returns: `Observable` interface.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func asObservable() -> Observable<E> {
return _values
}
@ -85,7 +85,7 @@ public struct ControlProperty<PropertyType> : ControlPropertyType {
/**
- returns: `ControlProperty` interface.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func asControlProperty() -> ControlProperty<E> {
return self
}

2
RxCocoa/Common/CocoaUnits/Driver/ControlEvent+Driver.swift
View File

@ -17,7 +17,7 @@ extension ControlEvent {
`ControlEvent` already can't fail, so no special case needs to be handled.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func asDriver() -> Driver<E> {
return self.asDriver { (error) -> Driver<E> in
#if DEBUG

2
RxCocoa/Common/CocoaUnits/Driver/ControlProperty+Driver.swift
View File

@ -17,7 +17,7 @@ extension ControlProperty {
`ControlProperty` already can't fail, so no special case needs to be handled.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func asDriver() -> Driver<E> {
return self.asDriver { (error) -> Driver<E> in
#if DEBUG

28
RxCocoa/Common/CocoaUnits/Driver/Driver+Operators+arity.swift
View File

@ -23,7 +23,7 @@ extension Driver {
- parameter resultSelector: Function to invoke for each series of elements at corresponding indexes in the sources.
- returns: An observable sequence containing the result of combining elements of the sources using the specified result selector function.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public static func zip<O1: DriverConvertibleType, O2: DriverConvertibleType>
(_ source1: O1, _ source2: O2, resultSelector: (O1.E, O2.E) throws -> E)
-> Driver<E> {
@ -43,7 +43,7 @@ extension Driver {
- parameter resultSelector: Function to invoke whenever any of the sources produces an element.
- returns: An observable sequence containing the result of combining elements of the sources using the specified result selector function.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public static func combineLatest<O1: DriverConvertibleType, O2: DriverConvertibleType>
(_ source1: O1, _ source2: O2, resultSelector: (O1.E, O2.E) throws -> E)
-> Driver<E> {
@ -67,7 +67,7 @@ extension Driver {
- parameter resultSelector: Function to invoke for each series of elements at corresponding indexes in the sources.
- returns: An observable sequence containing the result of combining elements of the sources using the specified result selector function.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public static func zip<O1: DriverConvertibleType, O2: DriverConvertibleType, O3: DriverConvertibleType>
(_ source1: O1, _ source2: O2, _ source3: O3, resultSelector: (O1.E, O2.E, O3.E) throws -> E)
-> Driver<E> {
@ -87,7 +87,7 @@ extension Driver {
- parameter resultSelector: Function to invoke whenever any of the sources produces an element.
- returns: An observable sequence containing the result of combining elements of the sources using the specified result selector function.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public static func combineLatest<O1: DriverConvertibleType, O2: DriverConvertibleType, O3: DriverConvertibleType>
(_ source1: O1, _ source2: O2, _ source3: O3, resultSelector: (O1.E, O2.E, O3.E) throws -> E)
-> Driver<E> {
@ -111,7 +111,7 @@ extension Driver {
- parameter resultSelector: Function to invoke for each series of elements at corresponding indexes in the sources.
- returns: An observable sequence containing the result of combining elements of the sources using the specified result selector function.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public static func zip<O1: DriverConvertibleType, O2: DriverConvertibleType, O3: DriverConvertibleType, O4: DriverConvertibleType>
(_ source1: O1, _ source2: O2, _ source3: O3, _ source4: O4, resultSelector: (O1.E, O2.E, O3.E, O4.E) throws -> E)
-> Driver<E> {
@ -131,7 +131,7 @@ extension Driver {
- parameter resultSelector: Function to invoke whenever any of the sources produces an element.
- returns: An observable sequence containing the result of combining elements of the sources using the specified result selector function.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public static func combineLatest<O1: DriverConvertibleType, O2: DriverConvertibleType, O3: DriverConvertibleType, O4: DriverConvertibleType>
(_ source1: O1, _ source2: O2, _ source3: O3, _ source4: O4, resultSelector: (O1.E, O2.E, O3.E, O4.E) throws -> E)
-> Driver<E> {
@ -155,7 +155,7 @@ extension Driver {
- parameter resultSelector: Function to invoke for each series of elements at corresponding indexes in the sources.
- returns: An observable sequence containing the result of combining elements of the sources using the specified result selector function.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public static func zip<O1: DriverConvertibleType, O2: DriverConvertibleType, O3: DriverConvertibleType, O4: DriverConvertibleType, O5: DriverConvertibleType>
(_ source1: O1, _ source2: O2, _ source3: O3, _ source4: O4, _ source5: O5, resultSelector: (O1.E, O2.E, O3.E, O4.E, O5.E) throws -> E)
-> Driver<E> {
@ -175,7 +175,7 @@ extension Driver {
- parameter resultSelector: Function to invoke whenever any of the sources produces an element.
- returns: An observable sequence containing the result of combining elements of the sources using the specified result selector function.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public static func combineLatest<O1: DriverConvertibleType, O2: DriverConvertibleType, O3: DriverConvertibleType, O4: DriverConvertibleType, O5: DriverConvertibleType>
(_ source1: O1, _ source2: O2, _ source3: O3, _ source4: O4, _ source5: O5, resultSelector: (O1.E, O2.E, O3.E, O4.E, O5.E) throws -> E)
-> Driver<E> {
@ -199,7 +199,7 @@ extension Driver {
- parameter resultSelector: Function to invoke for each series of elements at corresponding indexes in the sources.
- returns: An observable sequence containing the result of combining elements of the sources using the specified result selector function.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public static func zip<O1: DriverConvertibleType, O2: DriverConvertibleType, O3: DriverConvertibleType, O4: DriverConvertibleType, O5: DriverConvertibleType, O6: DriverConvertibleType>
(_ source1: O1, _ source2: O2, _ source3: O3, _ source4: O4, _ source5: O5, _ source6: O6, resultSelector: (O1.E, O2.E, O3.E, O4.E, O5.E, O6.E) throws -> E)
-> Driver<E> {
@ -219,7 +219,7 @@ extension Driver {
- parameter resultSelector: Function to invoke whenever any of the sources produces an element.
- returns: An observable sequence containing the result of combining elements of the sources using the specified result selector function.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public static func combineLatest<O1: DriverConvertibleType, O2: DriverConvertibleType, O3: DriverConvertibleType, O4: DriverConvertibleType, O5: DriverConvertibleType, O6: DriverConvertibleType>
(_ source1: O1, _ source2: O2, _ source3: O3, _ source4: O4, _ source5: O5, _ source6: O6, resultSelector: (O1.E, O2.E, O3.E, O4.E, O5.E, O6.E) throws -> E)
-> Driver<E> {
@ -243,7 +243,7 @@ extension Driver {
- parameter resultSelector: Function to invoke for each series of elements at corresponding indexes in the sources.
- returns: An observable sequence containing the result of combining elements of the sources using the specified result selector function.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public static func zip<O1: DriverConvertibleType, O2: DriverConvertibleType, O3: DriverConvertibleType, O4: DriverConvertibleType, O5: DriverConvertibleType, O6: DriverConvertibleType, O7: DriverConvertibleType>
(_ source1: O1, _ source2: O2, _ source3: O3, _ source4: O4, _ source5: O5, _ source6: O6, _ source7: O7, resultSelector: (O1.E, O2.E, O3.E, O4.E, O5.E, O6.E, O7.E) throws -> E)
-> Driver<E> {
@ -263,7 +263,7 @@ extension Driver {
- parameter resultSelector: Function to invoke whenever any of the sources produces an element.
- returns: An observable sequence containing the result of combining elements of the sources using the specified result selector function.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public static func combineLatest<O1: DriverConvertibleType, O2: DriverConvertibleType, O3: DriverConvertibleType, O4: DriverConvertibleType, O5: DriverConvertibleType, O6: DriverConvertibleType, O7: DriverConvertibleType>
(_ source1: O1, _ source2: O2, _ source3: O3, _ source4: O4, _ source5: O5, _ source6: O6, _ source7: O7, resultSelector: (O1.E, O2.E, O3.E, O4.E, O5.E, O6.E, O7.E) throws -> E)
-> Driver<E> {
@ -287,7 +287,7 @@ extension Driver {
- parameter resultSelector: Function to invoke for each series of elements at corresponding indexes in the sources.
- returns: An observable sequence containing the result of combining elements of the sources using the specified result selector function.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public static func zip<O1: DriverConvertibleType, O2: DriverConvertibleType, O3: DriverConvertibleType, O4: DriverConvertibleType, O5: DriverConvertibleType, O6: DriverConvertibleType, O7: DriverConvertibleType, O8: DriverConvertibleType>
(_ source1: O1, _ source2: O2, _ source3: O3, _ source4: O4, _ source5: O5, _ source6: O6, _ source7: O7, _ source8: O8, resultSelector: (O1.E, O2.E, O3.E, O4.E, O5.E, O6.E, O7.E, O8.E) throws -> E)
-> Driver<E> {
@ -307,7 +307,7 @@ extension Driver {
- parameter resultSelector: Function to invoke whenever any of the sources produces an element.
- returns: An observable sequence containing the result of combining elements of the sources using the specified result selector function.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public static func combineLatest<O1: DriverConvertibleType, O2: DriverConvertibleType, O3: DriverConvertibleType, O4: DriverConvertibleType, O5: DriverConvertibleType, O6: DriverConvertibleType, O7: DriverConvertibleType, O8: DriverConvertibleType>
(_ source1: O1, _ source2: O2, _ source3: O3, _ source4: O4, _ source5: O5, _ source6: O6, _ source7: O7, _ source8: O8, resultSelector: (O1.E, O2.E, O3.E, O4.E, O5.E, O6.E, O7.E, O8.E) throws -> E)
-> Driver<E> {

4
RxCocoa/Common/CocoaUnits/Driver/Driver+Operators+arity.tt
View File

@ -22,7 +22,7 @@ extension Driver {
- parameter resultSelector: Function to invoke for each series of elements at corresponding indexes in the sources.
- returns: An observable sequence containing the result of combining elements of the sources using the specified result selector function.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public static func zip<<%= (Array(1...i).map { "O\($0): DriverConvertibleType" }).joinWithSeparator(", ") %>>
(<%= (Array(1...i).map { "source\($0): O\($0)" }).joinWithSeparator(", _ ") %>, resultSelector: (<%= (Array(1...i).map { "O\($0).E" }).joinWithSeparator(", ") %>) throws -> E)
-> Driver<E> {
@ -42,7 +42,7 @@ extension Driver {
- parameter resultSelector: Function to invoke whenever any of the sources produces an element.
- returns: An observable sequence containing the result of combining elements of the sources using the specified result selector function.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public static func combineLatest<<%= (Array(1...i).map { "O\($0): DriverConvertibleType" }).joinWithSeparator(", ") %>>
(<%= (Array(1...i).map { "source\($0): O\($0)" }).joinWithSeparator(", _ ") %>, resultSelector: (<%= (Array(1...i).map { "O\($0).E" }).joinWithSeparator(", ") %>) throws -> E)
-> Driver<E> {

52
RxCocoa/Common/CocoaUnits/Driver/Driver+Operators.swift
View File

@ -20,7 +20,7 @@ extension DriverConvertibleType {
- parameter selector: A transform function to apply to each source element.
- returns: An observable sequence whose elements are the result of invoking the transform function on each element of source.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func map<R>(_ selector: (E) -> R) -> Driver<R> {
let source = self
.asObservable()
@ -37,7 +37,7 @@ extension DriverConvertibleType {
- parameter predicate: A function to test each source element for a condition.
- returns: An observable sequence that contains elements from the input sequence that satisfy the condition.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func filter(_ predicate: (E) -> Bool) -> Driver<E> {
let source = self
.asObservable()
@ -58,7 +58,7 @@ extension DriverConvertibleType where E : DriverConvertibleType {
- returns: The observable sequence that at any point in time produces the elements of the most recent inner observable sequence that has been received.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func switchLatest() -> Driver<E.E> {
let source: Observable<E.E> = self
.asObservable()
@ -80,7 +80,7 @@ extension DriverConvertibleType {
- returns: An observable sequence whose elements are the result of invoking the transform function on each element of source producing an
Observable of Observable sequences and that at any point in time produces the elements of the most recent inner observable sequence that has been received.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func flatMapLatest<R>(_ selector: (E) -> Driver<R>)
-> Driver<R> {
let source: Observable<R> = self
@ -100,7 +100,7 @@ extension DriverConvertibleType {
- parameter selector: A transform function to apply to element that was observed while no observable is executing in parallel.
- returns: An observable sequence whose elements are the result of invoking the one-to-many transform function on each element of the input sequence that was received while no other sequence was being calculated.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func flatMapFirst<R>(_ selector: (E) -> Driver<R>)
-> Driver<R> {
let source: Observable<R> = self
@ -119,7 +119,7 @@ extension DriverConvertibleType {
- parameter eventHandler: Action to invoke for each event in the observable sequence.
- returns: The source sequence with the side-effecting behavior applied.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func doOn(_ eventHandler: (Event<E>) -> Void)
-> Driver<E> {
let source = self.asObservable()
@ -136,7 +136,7 @@ extension DriverConvertibleType {
- parameter onCompleted: Action to invoke upon graceful termination of the observable sequence.
- returns: The source sequence with the side-effecting behavior applied.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func doOn(_ onNext: ((E) -> Void)? = nil, onError: ((ErrorProtocol) -> Void)? = nil, onCompleted: (() -> Void)? = nil)
-> Driver<E> {
let source = self.asObservable()
@ -151,7 +151,7 @@ extension DriverConvertibleType {
- parameter onNext: Action to invoke for each element in the observable sequence.
- returns: The source sequence with the side-effecting behavior applied.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func doOnNext(_ onNext: ((E) -> Void))
-> Driver<E> {
return self.doOn(onNext)
@ -163,7 +163,7 @@ extension DriverConvertibleType {
- parameter onCompleted: Action to invoke upon graceful termination of the observable sequence.
- returns: The source sequence with the side-effecting behavior applied.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func doOnCompleted(_ onCompleted: (() -> Void))
-> Driver<E> {
return self.doOn(onCompleted: onCompleted)
@ -179,7 +179,7 @@ extension DriverConvertibleType {
- parameter identifier: Identifier that is printed together with event description to standard output.
- returns: An observable sequence whose events are printed to standard output.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func debug(_ identifier: String? = nil, file: String = #file, line: UInt = #line, function: String = #function) -> Driver<E> {
let source = self.asObservable()
.debug(identifier, file: file, line: line, function: function)
@ -195,7 +195,7 @@ extension DriverConvertibleType where E: Equatable {
- returns: An observable sequence only containing the distinct contiguous elements, based on equality operator, from the source sequence.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func distinctUntilChanged()
-> Driver<E> {
let source = self.asObservable()
@ -213,7 +213,7 @@ extension DriverConvertibleType {
- parameter keySelector: A function to compute the comparison key for each element.
- returns: An observable sequence only containing the distinct contiguous elements, based on a computed key value, from the source sequence.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func distinctUntilChanged<K: Equatable>(_ keySelector: (E) -> K) -> Driver<E> {
let source = self.asObservable()
.distinctUntilChanged(keySelector, comparer: { $0 == $1 })
@ -226,7 +226,7 @@ extension DriverConvertibleType {
- parameter comparer: Equality comparer for computed key values.
- returns: An observable sequence only containing the distinct contiguous elements, based on `comparer`, from the source sequence.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func distinctUntilChanged(_ comparer: (lhs: E, rhs: E) -> Bool) -> Driver<E> {
let source = self.asObservable()
.distinctUntilChanged({ $0 }, comparer: comparer)
@ -240,7 +240,7 @@ extension DriverConvertibleType {
- parameter comparer: Equality comparer for computed key values.
- returns: An observable sequence only containing the distinct contiguous elements, based on a computed key value and the comparer, from the source sequence.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func distinctUntilChanged<K>(_ keySelector: (E) -> K, comparer: (lhs: K, rhs: K) -> Bool) -> Driver<E> {
let source = self.asObservable()
.distinctUntilChanged(keySelector, comparer: comparer)
@ -258,7 +258,7 @@ extension DriverConvertibleType {
- parameter selector: A transform function to apply to each element.
- returns: An observable sequence whose elements are the result of invoking the one-to-many transform function on each element of the input sequence.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func flatMap<R>(_ selector: (E) -> Driver<R>) -> Driver<R> {
let source = self.asObservable()
.flatMap(selector)
@ -276,7 +276,7 @@ extension DriverConvertibleType where E : DriverConvertibleType {
- parameter maxConcurrent: Maximum number of inner observable sequences being subscribed to concurrently.
- returns: The observable sequence that merges the elements of the observable sequences.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func merge() -> Driver<E.E> {
let source = self.asObservable()
.map { $0.asDriver() }
@ -289,7 +289,7 @@ extension DriverConvertibleType where E : DriverConvertibleType {
- returns: The observable sequence that merges the elements of the inner sequences.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func merge(maxConcurrent: Int)
-> Driver<E.E> {
let source = self.asObservable()
@ -310,7 +310,7 @@ extension DriverConvertibleType {
- parameter dueTime: Throttling duration for each element.
- returns: The throttled sequence.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func throttle(_ dueTime: RxTimeInterval)
-> Driver<E> {
let source = self.asObservable()
@ -327,7 +327,7 @@ extension DriverConvertibleType {
- parameter dueTime: Throttling duration for each element.
- returns: The throttled sequence.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func debounce(_ dueTime: RxTimeInterval)
-> Driver<E> {
let source = self.asObservable()
@ -348,7 +348,7 @@ extension DriverConvertibleType {
- parameter accumulator: An accumulator function to be invoked on each element.
- returns: An observable sequence containing the accumulated values.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func scan<A>(_ seed: A, accumulator: (A, E) -> A)
-> Driver<A> {
let source = self.asObservable()
@ -365,7 +365,7 @@ extension Sequence where Iterator.Element : DriverConvertibleType {
- returns: An observable sequence that contains the elements of each given sequence, in sequential order.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func concat()
-> Driver<Iterator.Element.E> {
let source = self.lazy.map { $0.asDriver().asObservable() }.concat()
@ -380,7 +380,7 @@ extension Collection where Iterator.Element : DriverConvertibleType {
- returns: An observable sequence that contains the elements of each given sequence, in sequential order.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func concat()
-> Driver<Generator.Element.E> {
let source = self.map { $0.asDriver().asObservable() }.concat()
@ -397,7 +397,7 @@ extension Collection where Iterator.Element : DriverConvertibleType {
- parameter resultSelector: Function to invoke for each series of elements at corresponding indexes in the sources.
- returns: An observable sequence containing the result of combining elements of the sources using the specified result selector function.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func zip<R>(_ resultSelector: ([Generator.Element.E]) throws -> R) -> Driver<R> {
let source = self.map { $0.asDriver().asObservable() }.zip(resultSelector: resultSelector)
return Driver<R>(source)
@ -413,7 +413,7 @@ extension Collection where Iterator.Element : DriverConvertibleType {
- parameter resultSelector: Function to invoke whenever any of the sources produces an element.
- returns: An observable sequence containing the result of combining elements of the sources using the specified result selector function.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func combineLatest<R>(_ resultSelector: ([Generator.Element.E]) throws -> R) -> Driver<R> {
let source = self.map { $0.asDriver().asObservable() }.combineLatest(resultSelector: resultSelector)
return Driver<R>(source)
@ -462,7 +462,7 @@ extension DriverConvertibleType {
- parameter count: The number of elements to skip before returning the remaining elements.
- returns: An observable sequence that contains the elements that occur after the specified index in the input sequence.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func skip(_ count: Int)
-> Driver<E> {
let source = self.asObservable()
@ -482,7 +482,7 @@ extension DriverConvertibleType {
- parameter element: Element to prepend to the specified sequence.
- returns: The source sequence prepended with the specified values.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func startWith(_ element: E)
-> Driver<E> {
let source = self.asObservable()

12
RxCocoa/Common/CocoaUnits/Driver/Driver+Subscription.swift
View File

@ -24,7 +24,7 @@ extension DriverConvertibleType {
- parameter observer: Observer that receives events.
- returns: Disposable object that can be used to unsubscribe the observer from the subject.
*/
@warn_unused_result(message:"http://git.io/rxs.ud")
// @warn_unused_result(message:"http://git.io/rxs.ud")
public func drive<O: ObserverType where O.E == E>(_ observer: O) -> Disposable {
MainScheduler.ensureExecutingOnScheduler(errorMessage: driverErrorMessage)
return self.asObservable().subscribe(observer)
@ -37,7 +37,7 @@ extension DriverConvertibleType {
- parameter variable: Target variable for sequence elements.
- returns: Disposable object that can be used to unsubscribe the observer from the variable.
*/
@warn_unused_result(message:"http://git.io/rxs.ud")
// @warn_unused_result(message:"http://git.io/rxs.ud")
public func drive(_ variable: Variable<E>) -> Disposable {
MainScheduler.ensureExecutingOnScheduler(errorMessage: driverErrorMessage)
return drive(onNext: { e in
@ -52,7 +52,7 @@ extension DriverConvertibleType {
- parameter with: Function used to bind elements from `self`.
- returns: Object representing subscription.
*/
@warn_unused_result(message:"http://git.io/rxs.ud")
// @warn_unused_result(message:"http://git.io/rxs.ud")
public func drive<R>(_ transformation: (Observable<E>) -> R) -> R {
MainScheduler.ensureExecutingOnScheduler(errorMessage: driverErrorMessage)
return transformation(self.asObservable())
@ -72,7 +72,7 @@ extension DriverConvertibleType {
- parameter curriedArgument: Final argument passed to `binder` to finish binding process.
- returns: Object representing subscription.
*/
@warn_unused_result(message:"http://git.io/rxs.ud")
// @warn_unused_result(message:"http://git.io/rxs.ud")
public func drive<R1, R2>(_ with: (Observable<E>) -> (R1) -> R2, curriedArgument: R1) -> R2 {
MainScheduler.ensureExecutingOnScheduler(errorMessage: driverErrorMessage)
return with(self.asObservable())(curriedArgument)
@ -91,7 +91,7 @@ extension DriverConvertibleType {
gracefully completed, errored, or if the generation is cancelled by disposing subscription)
- returns: Subscription object used to unsubscribe from the observable sequence.
*/
@warn_unused_result(message:"http://git.io/rxs.ud")
// @warn_unused_result(message:"http://git.io/rxs.ud")
public func drive(onNext: ((E) -> Void)? = nil, onCompleted: (() -> Void)? = nil, onDisposed: (() -> Void)? = nil) -> Disposable {
MainScheduler.ensureExecutingOnScheduler(errorMessage: driverErrorMessage)
return self.asObservable().subscribe(onNext: onNext, onCompleted: onCompleted, onDisposed: onDisposed)
@ -104,7 +104,7 @@ extension DriverConvertibleType {
- parameter onNext: Action to invoke for each element in the observable sequence.
- returns: Subscription object used to unsubscribe from the observable sequence.
*/
@warn_unused_result(message:"http://git.io/rxs.ud")
// @warn_unused_result(message:"http://git.io/rxs.ud")
public func driveNext(_ onNext: (E) -> Void) -> Disposable {
MainScheduler.ensureExecutingOnScheduler(errorMessage: driverErrorMessage)
return self.asObservable().subscribeNext(onNext)

22
RxCocoa/Common/CocoaUnits/Driver/Driver.swift
View File

@ -19,12 +19,12 @@ public protocol DriverConvertibleType : ObservableConvertibleType {
/**
Converts self to `Driver`.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
func asDriver() -> Driver<E>
}
extension DriverConvertibleType {
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func asObservable() -> Observable<E> {
return asDriver().asObservable()
}
@ -75,7 +75,7 @@ public struct Driver<Element> : DriverConvertibleType {
/**
- returns: Built observable sequence.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func asObservable() -> Observable<E> {
return _source
}
@ -83,7 +83,7 @@ public struct Driver<Element> : DriverConvertibleType {
/**
- returns: `self`
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func asDriver() -> Driver<E> {
return self
}
@ -97,7 +97,7 @@ extension Driver {
- returns: An observable sequence with no elements.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public static func empty() -> Driver<E> {
return Driver(Observable.empty().subscribeOn(driverSubscribeOnScheduler))
}
@ -107,7 +107,7 @@ extension Driver {
- returns: An observable sequence whose observers will never get called.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public static func never() -> Driver<E> {
return Driver(Observable.never().subscribeOn(driverSubscribeOnScheduler))
}
@ -118,7 +118,7 @@ extension Driver {
- parameter element: Single element in the resulting observable sequence.
- returns: An observable sequence containing the single specified element.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public static func just(_ element: E) -> Driver<E> {
return Driver(Observable.just(element).subscribeOn(driverSubscribeOnScheduler))
}
@ -129,7 +129,7 @@ extension Driver {
- parameter observableFactory: Observable factory function to invoke for each observer that subscribes to the resulting sequence.
- returns: An observable sequence whose observers trigger an invocation of the given observable factory function.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public static func deferred(_ observableFactory: () -> Driver<E>)
-> Driver<E> {
return Driver(Observable.deferred { observableFactory().asObservable() })
@ -143,7 +143,7 @@ extension Driver {
- parameter elements: Elements to generate.
- returns: The observable sequence whose elements are pulled from the given arguments.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public static func of(_ elements: E ...) -> Driver<E> {
let source = elements.toObservable(driverSubscribeOnScheduler)
return Driver(raw: source)
@ -159,7 +159,7 @@ extension Driver where Element : SignedInteger {
- parameter period: Period for producing the values in the resulting sequence.
- returns: An observable sequence that produces a value after each period.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public static func interval(_ period: RxTimeInterval)
-> Driver<E> {
return Driver(Observable.interval(period, scheduler: driverObserveOnScheduler))
@ -178,7 +178,7 @@ extension Driver where Element: SignedInteger {
- parameter period: Period to produce subsequent values.
- returns: An observable sequence that produces a value after due time has elapsed and then each period.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public static func timer(_ dueTime: RxTimeInterval, period: RxTimeInterval)
-> Driver<E> {
return Driver(Observable.timer(dueTime, period: period, scheduler: driverObserveOnScheduler))

6
RxCocoa/Common/CocoaUnits/Driver/ObservableConvertibleType+Driver.swift
View File

@ -18,7 +18,7 @@ extension ObservableConvertibleType {
- parameter onErrorJustReturn: Element to return in case of error and after that complete the sequence.
- returns: Driving observable sequence.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func asDriver(onErrorJustReturn: E) -> Driver<E> {
let source = self
.asObservable()
@ -33,7 +33,7 @@ extension ObservableConvertibleType {
- parameter onErrorDriveWith: Driver that continues to drive the sequence in case of error.
- returns: Driving observable sequence.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func asDriver(onErrorDriveWith: Driver<E>) -> Driver<E> {
let source = self
.asObservable()
@ -50,7 +50,7 @@ extension ObservableConvertibleType {
- parameter onErrorRecover: Calculates driver that continues to drive the sequence in case of error.
- returns: Driving observable sequence.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func asDriver(onErrorRecover: (error: ErrorProtocol) -> Driver<E>) -> Driver<E> {
let source = self
.asObservable()

2
RxCocoa/Common/CocoaUnits/Driver/Variable+Driver.swift
View File

@ -17,7 +17,7 @@ extension Variable {
- returns: Driving observable sequence.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func asDriver() -> Driver<E> {
let source = self.asObservable()
.observeOn(driverObserveOnScheduler)

10
RxCocoa/Common/Observable+Bind.swift
View File

@ -22,7 +22,7 @@ extension ObservableType {
- parameter observer: Observer that receives events.
- returns: Disposable object that can be used to unsubscribe the observer.
*/
@warn_unused_result(message: "http://git.io/rxs.ud")
// @warn_unused_result(message: "http://git.io/rxs.ud")
public func bindTo<O: ObserverType where O.E == E>(_ observer: O) -> Disposable {
return self.subscribe(observer)
}
@ -36,7 +36,7 @@ extension ObservableType {
- parameter variable: Target variable for sequence elements.
- returns: Disposable object that can be used to unsubscribe the observer.
*/
@warn_unused_result(message: "http://git.io/rxs.ud")
// @warn_unused_result(message: "http://git.io/rxs.ud")
public func bindTo(_ variable: Variable<E>) -> Disposable {
return subscribe { e in
switch e {
@ -61,7 +61,7 @@ extension ObservableType {
- parameter binder: Function used to bind elements from `self`.
- returns: Object representing subscription.
*/
@warn_unused_result(message: "http://git.io/rxs.ud")
// @warn_unused_result(message: "http://git.io/rxs.ud")
public func bindTo<R>(_ binder: (Self) -> R) -> R {
return binder(self)
}
@ -78,7 +78,7 @@ extension ObservableType {
- parameter curriedArgument: Final argument passed to `binder` to finish binding process.
- returns: Object representing subscription.
*/
@warn_unused_result(message: "http://git.io/rxs.ud")
// @warn_unused_result(message: "http://git.io/rxs.ud")
public func bindTo<R1, R2>(_ binder: (Self) -> (R1) -> R2, curriedArgument: R1) -> R2 {
return binder(self)(curriedArgument)
}
@ -93,7 +93,7 @@ extension ObservableType {
- parameter onNext: Action to invoke for each element in the observable sequence.
- returns: Subscription object used to unsubscribe from the observable sequence.
*/
@warn_unused_result(message: "http://git.io/rxs.ud")
// @warn_unused_result(message: "http://git.io/rxs.ud")
public func bindNext(_ onNext: (E) -> Void) -> Disposable {
return subscribe(onNext: onNext, onError: { error in
let error = "Binding error: \(error)"

2
RxCocoa/Common/Observables/NSNotificationCenter+Rx.swift
View File

@ -19,7 +19,7 @@ extension NotificationCenter {
- parameter object: Optional object used to filter notifications.
- returns: Observable sequence of posted notifications.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func rx_notification(_ name: Notification.Name, object: AnyObject? = nil) -> Observable<Notification> {
return Observable.create { [weak object] observer in
let nsObserver = self.addObserver(forName: name, object: object, queue: nil) { notification in

4
RxCocoa/Common/Observables/NSObject+Rx+KVORepresentable.swift
View File

@ -21,7 +21,7 @@ extension NSObject {
For more information take a look at `rx_observe` method.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func rx_observe<E: KVORepresentable>(_ type: E.Type, _ keyPath: String, options: NSKeyValueObservingOptions = [.new, .initial], retainSelf: Bool = true) -> Observable<E?> {
return rx_observe(E.KVOType.self, keyPath, options: options, retainSelf: retainSelf)
.map(E.init)
@ -36,7 +36,7 @@ extension NSObject {
For more information take a look at `rx_observeWeakly` method.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func rx_observeWeakly<E: KVORepresentable>(_ type: E.Type, _ keyPath: String, options: NSKeyValueObservingOptions = [.new, .initial]) -> Observable<E?> {
return rx_observeWeakly(E.KVOType.self, keyPath, options: options)
.map(E.init)

4
RxCocoa/Common/Observables/NSObject+Rx+RawRepresentable.swift
View File

@ -21,7 +21,7 @@ extension NSObject {
For more information take a look at `rx_observe` method.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func rx_observe<E: RawRepresentable where E.RawValue: KVORepresentable>(_ type: E.Type, _ keyPath: String, options: NSKeyValueObservingOptions = [.new, .initial], retainSelf: Bool = true) -> Observable<E?> {
return rx_observe(E.RawValue.KVOType.self, keyPath, options: options, retainSelf: retainSelf)
.map(E.init)
@ -42,7 +42,7 @@ extension NSObject {
For more information take a look at `rx_observeWeakly` method.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func rx_observeWeakly<E: RawRepresentable where E.RawValue: KVORepresentable>(_ type: E.Type, _ keyPath: String, options: NSKeyValueObservingOptions = [.new, .initial]) -> Observable<E?> {
return rx_observeWeakly(E.RawValue.KVOType.self, keyPath, options: options)
.map(E.init)

4
RxCocoa/Common/Observables/NSObject+Rx.swift
View File

@ -58,7 +58,7 @@ extension NSObject {
- parameter retainSelf: Retains self during observation if set `true`.
- returns: Observable sequence of objects on `keyPath`.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func rx_observe<E>(_ type: E.Type, _ keyPath: String, options: NSKeyValueObservingOptions = [.new, .initial], retainSelf: Bool = true) -> Observable<E?> {
return KVOObservable(object: self, keyPath: keyPath, options: options, retainTarget: retainSelf).asObservable()
}
@ -81,7 +81,7 @@ extension NSObject {
- parameter options: KVO mechanism notification options.
- returns: Observable sequence of objects on `keyPath`.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func rx_observeWeakly<E>(_ type: E.Type, _ keyPath: String, options: NSKeyValueObservingOptions = [.new, .initial]) -> Observable<E?> {
return observeWeaklyKeyPathFor(self, keyPath: keyPath, options: options)
.map { n in

8
RxCocoa/Common/Observables/NSURLSession+Rx.swift
View File

@ -118,7 +118,7 @@ extension URLSession {
- parameter request: URL request.
- returns: Observable sequence of URL responses.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func rx_response(_ request: URLRequest) -> Observable<(Data, HTTPURLResponse)> {
return Observable.create { observer in
@ -174,7 +174,7 @@ extension URLSession {
- parameter request: URL request.
- returns: Observable sequence of response data.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func rx_data(_ request: URLRequest) -> Observable<Data> {
return rx_response(request).map { (data, response) -> Data in
if 200 ..< 300 ~= response.statusCode {
@ -203,7 +203,7 @@ extension URLSession {
- parameter request: URL request.
- returns: Observable sequence of response JSON.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func rx_JSON(_ request: URLRequest) -> Observable<AnyObject> {
return rx_data(request).map { (data) -> AnyObject in
do {
@ -231,7 +231,7 @@ extension URLSession {
- parameter URL: URL of `NSURLRequest` request.
- returns: Observable sequence of response JSON.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func rx_JSON(_ URL: Foundation.URL) -> Observable<AnyObject> {
return rx_JSON(URLRequest(url: URL))
}

12
RxSwift/Observable+Extensions.swift
View File

@ -15,7 +15,7 @@ extension ObservableType {
- parameter on: Action to invoke for each event in the observable sequence.
- returns: Subscription object used to unsubscribe from the observable sequence.
*/
@warn_unused_result(message: "http://git.io/rxs.ud")
// @warn_unused_result(message: "http://git.io/rxs.ud")
public func subscribe(_ on: (event: Event<E>) -> Void)
-> Disposable {
let observer = AnonymousObserver { e in
@ -34,7 +34,7 @@ extension ObservableType {
gracefully completed, errored, or if the generation is cancelled by disposing subscription).
- returns: Subscription object used to unsubscribe from the observable sequence.
*/
@warn_unused_result(message: "http://git.io/rxs.ud")
// @warn_unused_result(message: "http://git.io/rxs.ud")
public func subscribe(onNext: ((E) -> Void)? = nil, onError: ((ErrorProtocol) -> Void)? = nil, onCompleted: (() -> Void)? = nil, onDisposed: (() -> Void)? = nil)
-> Disposable {
@ -71,7 +71,7 @@ extension ObservableType {
- parameter onNext: Action to invoke for each element in the observable sequence.
- returns: Subscription object used to unsubscribe from the observable sequence.
*/
@warn_unused_result(message: "http://git.io/rxs.ud")
// @warn_unused_result(message: "http://git.io/rxs.ud")
public func subscribeNext(_ onNext: (E) -> Void)
-> Disposable {
let observer = AnonymousObserver<E> { e in
@ -88,7 +88,7 @@ extension ObservableType {
- parameter onError: Action to invoke upon errored termination of the observable sequence.
- returns: Subscription object used to unsubscribe from the observable sequence.
*/
@warn_unused_result(message: "http://git.io/rxs.ud")
// @warn_unused_result(message: "http://git.io/rxs.ud")
public func subscribeError(_ onError: (ErrorProtocol) -> Void)
-> Disposable {
let observer = AnonymousObserver<E> { e in
@ -105,7 +105,7 @@ extension ObservableType {
- parameter onCompleted: Action to invoke upon graceful termination of the observable sequence.
- returns: Subscription object used to unsubscribe from the observable sequence.
*/
@warn_unused_result(message: "http://git.io/rxs.ud")
// @warn_unused_result(message: "http://git.io/rxs.ud")
public func subscribeCompleted(_ onCompleted: () -> Void)
-> Disposable {
let observer = AnonymousObserver<E> { e in
@ -121,7 +121,7 @@ public extension ObservableType {
/**
All internal subscribe calls go through this method.
*/
@warn_unused_result(message: "http://git.io/rxs.ud")
// @warn_unused_result(message: "http://git.io/rxs.ud")
func subscribeSafe<O: ObserverType where O.E == E>(_ observer: O) -> Disposable {
return self.asObservable().subscribe(observer)
}

4
RxSwift/ObservableType.swift
View File

@ -40,7 +40,7 @@ public protocol ObservableType : ObservableConvertibleType {
- returns: Subscription for `observer` that can be used to cancel production of sequence elements and free resources.
*/
@warn_unused_result(message: "http://git.io/rxs.ud")
// @warn_unused_result(message: "http://git.io/rxs.ud")
func subscribe<O: ObserverType where O.E == E>(_ observer: O) -> Disposable
}
@ -50,7 +50,7 @@ extension ObservableType {
/**
Default implementation of converting `ObservableType` to `Observable`.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func asObservable() -> Observable<E> {
// temporary workaround
//return Observable.create(subscribe: self.subscribe)

14
RxSwift/Observables/Implementations/CombineLatest+arity.swift
View File

@ -22,7 +22,7 @@ extension Observable {
- parameter resultSelector: Function to invoke whenever any of the sources produces an element.
- returns: An observable sequence containing the result of combining elements of the sources using the specified result selector function.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public static func combineLatest<O1: ObservableType, O2: ObservableType>
(_ source1: O1, _ source2: O2, resultSelector: (O1.E, O2.E) throws -> E)
-> Observable<E> {
@ -103,7 +103,7 @@ extension Observable {
- parameter resultSelector: Function to invoke whenever any of the sources produces an element.
- returns: An observable sequence containing the result of combining elements of the sources using the specified result selector function.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public static func combineLatest<O1: ObservableType, O2: ObservableType, O3: ObservableType>
(_ source1: O1, _ source2: O2, _ source3: O3, resultSelector: (O1.E, O2.E, O3.E) throws -> E)
-> Observable<E> {
@ -191,7 +191,7 @@ extension Observable {
- parameter resultSelector: Function to invoke whenever any of the sources produces an element.
- returns: An observable sequence containing the result of combining elements of the sources using the specified result selector function.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public static func combineLatest<O1: ObservableType, O2: ObservableType, O3: ObservableType, O4: ObservableType>
(_ source1: O1, _ source2: O2, _ source3: O3, _ source4: O4, resultSelector: (O1.E, O2.E, O3.E, O4.E) throws -> E)
-> Observable<E> {
@ -286,7 +286,7 @@ extension Observable {
- parameter resultSelector: Function to invoke whenever any of the sources produces an element.
- returns: An observable sequence containing the result of combining elements of the sources using the specified result selector function.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public static func combineLatest<O1: ObservableType, O2: ObservableType, O3: ObservableType, O4: ObservableType, O5: ObservableType>
(_ source1: O1, _ source2: O2, _ source3: O3, _ source4: O4, _ source5: O5, resultSelector: (O1.E, O2.E, O3.E, O4.E, O5.E) throws -> E)
-> Observable<E> {
@ -388,7 +388,7 @@ extension Observable {
- parameter resultSelector: Function to invoke whenever any of the sources produces an element.
- returns: An observable sequence containing the result of combining elements of the sources using the specified result selector function.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public static func combineLatest<O1: ObservableType, O2: ObservableType, O3: ObservableType, O4: ObservableType, O5: ObservableType, O6: ObservableType>
(_ source1: O1, _ source2: O2, _ source3: O3, _ source4: O4, _ source5: O5, _ source6: O6, resultSelector: (O1.E, O2.E, O3.E, O4.E, O5.E, O6.E) throws -> E)
-> Observable<E> {
@ -497,7 +497,7 @@ extension Observable {
- parameter resultSelector: Function to invoke whenever any of the sources produces an element.
- returns: An observable sequence containing the result of combining elements of the sources using the specified result selector function.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public static func combineLatest<O1: ObservableType, O2: ObservableType, O3: ObservableType, O4: ObservableType, O5: ObservableType, O6: ObservableType, O7: ObservableType>
(_ source1: O1, _ source2: O2, _ source3: O3, _ source4: O4, _ source5: O5, _ source6: O6, _ source7: O7, resultSelector: (O1.E, O2.E, O3.E, O4.E, O5.E, O6.E, O7.E) throws -> E)
-> Observable<E> {
@ -613,7 +613,7 @@ extension Observable {
- parameter resultSelector: Function to invoke whenever any of the sources produces an element.
- returns: An observable sequence containing the result of combining elements of the sources using the specified result selector function.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public static func combineLatest<O1: ObservableType, O2: ObservableType, O3: ObservableType, O4: ObservableType, O5: ObservableType, O6: ObservableType, O7: ObservableType, O8: ObservableType>
(_ source1: O1, _ source2: O2, _ source3: O3, _ source4: O4, _ source5: O5, _ source6: O6, _ source7: O7, _ source8: O8, resultSelector: (O1.E, O2.E, O3.E, O4.E, O5.E, O6.E, O7.E, O8.E) throws -> E)
-> Observable<E> {

2
RxSwift/Observables/Implementations/CombineLatest+arity.tt
View File

@ -21,7 +21,7 @@ extension Observable {
- parameter resultSelector: Function to invoke whenever any of the sources produces an element.
- returns: An observable sequence containing the result of combining elements of the sources using the specified result selector function.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public static func combineLatest<<%= (Array(1...i).map { "O\($0): ObservableType" }).joinWithSeparator(", ") %>>
(<%= (Array(1...i).map { "_ source\($0): O\($0)" }).joinWithSeparator(", ") %>, resultSelector: (<%= (Array(1...i).map { "O\($0).E" }).joinWithSeparator(", ") %>) throws -> E)
-> Observable<E> {

14
RxSwift/Observables/Implementations/Zip+arity.swift
View File

@ -22,7 +22,7 @@ extension Observable {
- parameter resultSelector: Function to invoke for each series of elements at corresponding indexes in the sources.
- returns: An observable sequence containing the result of combining elements of the sources using the specified result selector function.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public static func zip<O1: ObservableType, O2: ObservableType>
(_ source1: O1, _ source2: O2, resultSelector: (O1.E, O2.E) throws -> E)
-> Observable<E> {
@ -115,7 +115,7 @@ extension Observable {
- parameter resultSelector: Function to invoke for each series of elements at corresponding indexes in the sources.
- returns: An observable sequence containing the result of combining elements of the sources using the specified result selector function.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public static func zip<O1: ObservableType, O2: ObservableType, O3: ObservableType>
(_ source1: O1, _ source2: O2, _ source3: O3, resultSelector: (O1.E, O2.E, O3.E) throws -> E)
-> Observable<E> {
@ -216,7 +216,7 @@ extension Observable {
- parameter resultSelector: Function to invoke for each series of elements at corresponding indexes in the sources.
- returns: An observable sequence containing the result of combining elements of the sources using the specified result selector function.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public static func zip<O1: ObservableType, O2: ObservableType, O3: ObservableType, O4: ObservableType>
(_ source1: O1, _ source2: O2, _ source3: O3, _ source4: O4, resultSelector: (O1.E, O2.E, O3.E, O4.E) throws -> E)
-> Observable<E> {
@ -325,7 +325,7 @@ extension Observable {
- parameter resultSelector: Function to invoke for each series of elements at corresponding indexes in the sources.
- returns: An observable sequence containing the result of combining elements of the sources using the specified result selector function.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public static func zip<O1: ObservableType, O2: ObservableType, O3: ObservableType, O4: ObservableType, O5: ObservableType>
(_ source1: O1, _ source2: O2, _ source3: O3, _ source4: O4, _ source5: O5, resultSelector: (O1.E, O2.E, O3.E, O4.E, O5.E) throws -> E)
-> Observable<E> {
@ -442,7 +442,7 @@ extension Observable {
- parameter resultSelector: Function to invoke for each series of elements at corresponding indexes in the sources.
- returns: An observable sequence containing the result of combining elements of the sources using the specified result selector function.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public static func zip<O1: ObservableType, O2: ObservableType, O3: ObservableType, O4: ObservableType, O5: ObservableType, O6: ObservableType>
(_ source1: O1, _ source2: O2, _ source3: O3, _ source4: O4, _ source5: O5, _ source6: O6, resultSelector: (O1.E, O2.E, O3.E, O4.E, O5.E, O6.E) throws -> E)
-> Observable<E> {
@ -567,7 +567,7 @@ extension Observable {
- parameter resultSelector: Function to invoke for each series of elements at corresponding indexes in the sources.
- returns: An observable sequence containing the result of combining elements of the sources using the specified result selector function.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public static func zip<O1: ObservableType, O2: ObservableType, O3: ObservableType, O4: ObservableType, O5: ObservableType, O6: ObservableType, O7: ObservableType>
(_ source1: O1, _ source2: O2, _ source3: O3, _ source4: O4, _ source5: O5, _ source6: O6, _ source7: O7, resultSelector: (O1.E, O2.E, O3.E, O4.E, O5.E, O6.E, O7.E) throws -> E)
-> Observable<E> {
@ -700,7 +700,7 @@ extension Observable {
- parameter resultSelector: Function to invoke for each series of elements at corresponding indexes in the sources.
- returns: An observable sequence containing the result of combining elements of the sources using the specified result selector function.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public static func zip<O1: ObservableType, O2: ObservableType, O3: ObservableType, O4: ObservableType, O5: ObservableType, O6: ObservableType, O7: ObservableType, O8: ObservableType>
(_ source1: O1, _ source2: O2, _ source3: O3, _ source4: O4, _ source5: O5, _ source6: O6, _ source7: O7, _ source8: O8, resultSelector: (O1.E, O2.E, O3.E, O4.E, O5.E, O6.E, O7.E, O8.E) throws -> E)
-> Observable<E> {

2
RxSwift/Observables/Implementations/Zip+arity.tt
View File

@ -21,7 +21,7 @@ extension Observable {
- parameter resultSelector: Function to invoke for each series of elements at corresponding indexes in the sources.
- returns: An observable sequence containing the result of combining elements of the sources using the specified result selector function.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public static func zip<<%= (Array(1...i).map { "O\($0): ObservableType" }).joinWithSeparator(", ") %>>
(<%= (Array(1...i).map { "_ source\($0): O\($0)" }).joinWithSeparator(", ") %>, resultSelector: (<%= (Array(1...i).map { "O\($0).E" }).joinWithSeparator(", ") %>) throws -> E)
-> Observable<E> {

6
RxSwift/Observables/Observable+Aggregate.swift
View File

@ -24,7 +24,7 @@ extension ObservableType {
- parameter mapResult: A function to transform the final accumulator value into the result value.
- returns: An observable sequence containing a single element with the final accumulator value.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func reduce<A, R>(_ seed: A, accumulator: (A, E) throws -> A, mapResult: (A) throws -> R)
-> Observable<R> {
return Reduce(source: self.asObservable(), seed: seed, accumulator: accumulator, mapResult: mapResult)
@ -41,7 +41,7 @@ extension ObservableType {
- parameter accumulator: A accumulator function to be invoked on each element.
- returns: An observable sequence containing a single element with the final accumulator value.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func reduce<A>(_ seed: A, accumulator: (A, E) throws -> A)
-> Observable<A> {
return Reduce(source: self.asObservable(), seed: seed, accumulator: accumulator, mapResult: { $0 })
@ -56,7 +56,7 @@ extension ObservableType {
- returns: An observable sequence containing all the emitted elements as array.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func toArray()
-> Observable<[E]> {
return ToArray(source: self.asObservable())

18
RxSwift/Observables/Observable+Binding.swift
View File

@ -24,7 +24,7 @@ extension ObservableType {
- parameter subject: Subject to push source elements into.
- returns: A connectable observable sequence that upon connection causes the source sequence to push results into the specified subject.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func multicast<S: SubjectType where S.SubjectObserverType.E == E>(_ subject: S)
-> ConnectableObservable<S.E> {
return ConnectableObservableAdapter(source: self.asObservable(), subject: subject)
@ -43,7 +43,7 @@ extension ObservableType {
- parameter selector: Selector function which can use the multicasted source sequence subject to the policies enforced by the created subject.
- returns: An observable sequence that contains the elements of a sequence produced by multicasting the source sequence within a selector function.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func multicast<S: SubjectType, R where S.SubjectObserverType.E == E>(_ subjectSelector: () throws -> S, selector: (Observable<S.E>) throws -> Observable<R>)
-> Observable<R> {
return Multicast(
@ -67,7 +67,7 @@ extension ObservableType {
- returns: A connectable observable sequence that shares a single subscription to the underlying sequence.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func publish() -> ConnectableObservable<E> {
return self.multicast(PublishSubject())
}
@ -87,7 +87,7 @@ extension ObservableType {
- parameter bufferSize: Maximum element count of the replay buffer.
- returns: A connectable observable sequence that shares a single subscription to the underlying sequence.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func replay(_ bufferSize: Int)
-> ConnectableObservable<E> {
return self.multicast(ReplaySubject.create(bufferSize: bufferSize))
@ -102,7 +102,7 @@ extension ObservableType {
- returns: A connectable observable sequence that shares a single subscription to the underlying sequence.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func replayAll()
-> ConnectableObservable<E> {
return self.multicast(ReplaySubject.createUnbounded())
@ -120,7 +120,7 @@ extension ConnectableObservableType {
- returns: An observable sequence that stays connected to the source as long as there is at least one subscription to the observable sequence.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func refCount() -> Observable<E> {
return RefCount(source: self)
}
@ -139,7 +139,7 @@ extension ObservableType {
- returns: An observable sequence that contains the elements of a sequence produced by multicasting the source sequence.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func share() -> Observable<E> {
return self.publish().refCount()
}
@ -159,7 +159,7 @@ extension ObservableType {
- parameter bufferSize: Maximum element count of the replay buffer.
- returns: An observable sequence that contains the elements of a sequence produced by multicasting the source sequence.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func shareReplay(_ bufferSize: Int)
-> Observable<E> {
if bufferSize == 1 {
@ -182,7 +182,7 @@ extension ObservableType {
- returns: An observable sequence that contains the elements of a sequence produced by multicasting the source sequence.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func shareReplayLatestWhileConnected()
-> Observable<E> {
return ShareReplay1WhileConnected(source: self.asObservable())

4
RxSwift/Observables/Observable+Concurrency.swift
View File

@ -23,7 +23,7 @@ extension ObservableType {
- parameter scheduler: Scheduler to notify observers on.
- returns: The source sequence whose observations happen on the specified scheduler.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func observeOn(_ scheduler: ImmediateSchedulerType)
-> Observable<E> {
if let scheduler = scheduler as? SerialDispatchQueueScheduler {
@ -54,7 +54,7 @@ extension ObservableType {
- parameter scheduler: Scheduler to perform subscription and unsubscription actions on.
- returns: The source sequence whose subscriptions and unsubscriptions happen on the specified scheduler.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func subscribeOn(_ scheduler: ImmediateSchedulerType)
-> Observable<E> {
return SubscribeOn(source: self, scheduler: scheduler)

26
RxSwift/Observables/Observable+Creation.swift
View File

@ -19,7 +19,7 @@ extension Observable {
- parameter subscribe: Implementation of the resulting observable sequence's `subscribe` method.
- returns: The observable sequence with the specified implementation for the `subscribe` method.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public static func create(_ subscribe: (AnyObserver<E>) -> Disposable) -> Observable<E> {
return AnonymousObservable(subscribe)
}
@ -33,7 +33,7 @@ extension Observable {
- returns: An observable sequence with no elements.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public static func empty() -> Observable<E> {
return Empty<E>()
}
@ -47,7 +47,7 @@ extension Observable {
- returns: An observable sequence whose observers will never get called.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public static func never() -> Observable<E> {
return Never()
}
@ -63,7 +63,7 @@ extension Observable {
- parameter: Scheduler to send the single element on.
- returns: An observable sequence containing the single specified element.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public static func just(_ element: E, scheduler: ImmediateSchedulerType? = nil) -> Observable<E> {
if let scheduler = scheduler {
return JustScheduled(element: element, scheduler: scheduler)
@ -82,7 +82,7 @@ extension Observable {
- returns: The observable sequence that terminates with specified error.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public static func error(_ error: ErrorProtocol) -> Observable<E> {
return Error(error: error)
}
@ -98,7 +98,7 @@ extension Observable {
- parameter scheduler: Scheduler to send elements on. If `nil`, elements are sent immediatelly on subscription.
- returns: The observable sequence whose elements are pulled from the given arguments.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public static func of(_ elements: E ..., scheduler: ImmediateSchedulerType? = nil) -> Observable<E> {
return ObservableSequence(elements: elements, scheduler: scheduler)
}
@ -113,7 +113,7 @@ extension Observable {
- parameter observableFactory: Observable factory function to invoke for each observer that subscribes to the resulting sequence.
- returns: An observable sequence whose observers trigger an invocation of the given observable factory function.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public static func deferred(_ observableFactory: () throws -> Observable<E>)
-> Observable<E> {
return Deferred(observableFactory: observableFactory)
@ -131,7 +131,7 @@ extension Observable {
- parameter scheduler: Scheduler on which to run the generator loop.
- returns: The generated sequence.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public static func generate(initialState: E, condition: (E) throws -> Bool, scheduler: ImmediateSchedulerType = CurrentThreadScheduler.instance, iterate: (E) throws -> E) -> Observable<E> {
return Generate(initialState: initialState, condition: condition, iterate: iterate, resultSelector: { $0 }, scheduler: scheduler)
}
@ -145,7 +145,7 @@ extension Observable {
- parameter scheduler: Scheduler to run the producer loop on.
- returns: An observable sequence that repeats the given element infinitely.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public static func repeatElement(_ element: E, scheduler: ImmediateSchedulerType = CurrentThreadScheduler.instance) -> Observable<E> {
return RepeatElement(element: element, scheduler: scheduler)
}
@ -159,7 +159,7 @@ extension Observable {
- parameter observableFactory: Factory function to obtain an observable sequence that depends on the obtained resource.
- returns: An observable sequence whose lifetime controls the lifetime of the dependent resource object.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public static func using<R: Disposable>(_ resourceFactory: () throws -> R, observableFactory: (R) throws -> Observable<E>) -> Observable<E> {
return Using(resourceFactory: resourceFactory, observableFactory: observableFactory)
}
@ -176,7 +176,7 @@ extension Observable where Element : SignedInteger {
- parameter scheduler: Scheduler to run the generator loop on.
- returns: An observable sequence that contains a range of sequential integral numbers.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public static func range(start: E, count: E, scheduler: ImmediateSchedulerType = CurrentThreadScheduler.instance) -> Observable<E> {
return RangeProducer<E>(start: start, count: count, scheduler: scheduler)
}
@ -190,7 +190,7 @@ extension Sequence {
- returns: The observable sequence whose elements are pulled from the given enumerable sequence.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func toObservable(_ scheduler: ImmediateSchedulerType? = nil) -> Observable<Iterator.Element> {
return ObservableSequence(elements: Array(self), scheduler: scheduler)
}
@ -204,7 +204,7 @@ extension Array {
- returns: The observable sequence whose elements are pulled from the given enumerable sequence.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func toObservable(_ scheduler: ImmediateSchedulerType? = nil) -> Observable<Iterator.Element> {
return ObservableSequence(elements: self, scheduler: scheduler)
}

2
RxSwift/Observables/Observable+Debug.swift
View File

@ -20,7 +20,7 @@ extension ObservableType {
- parameter identifier: Identifier that is printed together with event description to standard output.
- returns: An observable sequence whose events are printed to standard output.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func debug(_ identifier: String? = nil, file: String = #file, line: UInt = #line, function: String = #function)
-> Observable<E> {
return Debug(source: self.asObservable(), identifier: identifier, file: file, line: line, function: function)

32
RxSwift/Observables/Observable+Multiple.swift
View File

@ -20,7 +20,7 @@ extension Collection where Iterator.Element : ObservableType {
- parameter resultSelector: Function to invoke whenever any of the sources produces an element.
- returns: An observable sequence containing the result of combining elements of the sources using the specified result selector function.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func combineLatest<R>(resultSelector: ([Generator.Element.E]) throws -> R) -> Observable<R> {
return CombineLatestCollectionType(sources: self, resultSelector: resultSelector)
}
@ -38,7 +38,7 @@ extension Collection where Iterator.Element : ObservableType {
- parameter resultSelector: Function to invoke for each series of elements at corresponding indexes in the sources.
- returns: An observable sequence containing the result of combining elements of the sources using the specified result selector function.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func zip<R>(resultSelector: ([Generator.Element.E]) throws -> R) -> Observable<R> {
return ZipCollectionType(sources: self, resultSelector: resultSelector)
}
@ -59,7 +59,7 @@ extension ObservableType where E : ObservableConvertibleType {
- returns: The observable sequence that at any point in time produces the elements of the most recent inner observable sequence that has been received.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func switchLatest() -> Observable<E.E> {
return Switch(source: asObservable())
}
@ -77,7 +77,7 @@ extension ObservableType {
- parameter second: Second observable sequence.
- returns: An observable sequence that contains the elements of `self`, followed by those of the second sequence.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func concat<O: ObservableConvertibleType where O.E == E>(_ second: O) -> Observable<E> {
return [asObservable(), second.asObservable()].concat()
}
@ -98,7 +98,7 @@ extension Sequence where Iterator.Element : ObservableType {
- returns: An observable sequence that contains the elements of each given sequence, in sequential order.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func concat()
-> Observable<Iterator.Element.E> {
return Concat(sources: self, count: nil)
@ -121,7 +121,7 @@ extension Collection where Iterator.Element : ObservableType {
- returns: An observable sequence that contains the elements of each given sequence, in sequential order.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func concat()
-> Observable<Generator.Element.E> {
return Concat(sources: self, count: self.count.toIntMax())
@ -137,7 +137,7 @@ extension ObservableType where E : ObservableConvertibleType {
- returns: An observable sequence that contains the elements of each observed inner sequence, in sequential order.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func concat() -> Observable<E.E> {
return merge(maxConcurrent: 1)
}
@ -154,7 +154,7 @@ extension ObservableType where E : ObservableConvertibleType {
- returns: The observable sequence that merges the elements of the observable sequences.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func merge() -> Observable<E.E> {
return Merge(source: asObservable())
}
@ -167,7 +167,7 @@ extension ObservableType where E : ObservableConvertibleType {
- parameter maxConcurrent: Maximum number of inner observable sequences being subscribed to concurrently.
- returns: The observable sequence that merges the elements of the inner sequences.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func merge(maxConcurrent: Int)
-> Observable<E.E> {
return MergeLimited(source: asObservable(), maxConcurrent: maxConcurrent)
@ -186,7 +186,7 @@ extension ObservableType {
- parameter handler: Error handler function, producing another observable sequence.
- returns: An observable sequence containing the source sequence's elements, followed by the elements produced by the handler's resulting observable sequence in case an error occurred.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func catchError(_ handler: (ErrorProtocol) throws -> Observable<E>)
-> Observable<E> {
return Catch(source: asObservable(), handler: handler)
@ -200,7 +200,7 @@ extension ObservableType {
- parameter element: Last element in an observable sequence in case error occurs.
- returns: An observable sequence containing the source sequence's elements, followed by the `element` in case an error occurred.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func catchErrorJustReturn(_ element: E)
-> Observable<E> {
return Catch(source: asObservable(), handler: { _ in Observable.just(element) })
@ -216,7 +216,7 @@ extension Sequence where Iterator.Element : ObservableType {
- returns: An observable sequence containing elements from consecutive source sequences until a source sequence terminates successfully.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func catchError()
-> Observable<Iterator.Element.E> {
return CatchSequence(sources: self)
@ -235,7 +235,7 @@ extension ObservableType {
- parameter other: Observable sequence that terminates propagation of elements of the source sequence.
- returns: An observable sequence containing the elements of the source sequence up to the point the other sequence interrupted further propagation.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func takeUntil<O: ObservableType>(_ other: O)
-> Observable<E> {
return TakeUntil(source: asObservable(), other: other.asObservable())
@ -254,7 +254,7 @@ extension ObservableType {
- parameter other: Observable sequence that starts propagation of elements of the source sequence.
- returns: An observable sequence containing the elements of the source sequence that are emitted after the other sequence emits an item.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func skipUntil<O: ObservableType>(_ other: O)
-> Observable<E> {
return SkipUntil(source: asObservable(), other: other.asObservable())
@ -273,7 +273,7 @@ extension ObservableType {
- parameter right: Second observable sequence.
- returns: An observable sequence that surfaces either of the given sequences, whichever reacted first.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func amb<O2: ObservableType where O2.E == E>
(_ right: O2)
-> Observable<E> {
@ -290,7 +290,7 @@ extension Sequence where Iterator.Element : ObservableType {
- returns: An observable sequence that surfaces any of the given sequences, whichever reacted first.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func amb()
-> Observable<Iterator.Element.E> {
return self.reduce(Observable.never()) { a, o in

30
RxSwift/Observables/Observable+Single.swift
View File

@ -19,7 +19,7 @@ extension ObservableType where E: Equatable {
- returns: An observable sequence only containing the distinct contiguous elements, based on equality operator, from the source sequence.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func distinctUntilChanged()
-> Observable<E> {
return self.distinctUntilChanged({ $0 }, comparer: { ($0 == $1) })
@ -35,7 +35,7 @@ extension ObservableType {
- parameter keySelector: A function to compute the comparison key for each element.
- returns: An observable sequence only containing the distinct contiguous elements, based on a computed key value, from the source sequence.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func distinctUntilChanged<K: Equatable>(_ keySelector: (E) throws -> K)
-> Observable<E> {
return self.distinctUntilChanged(keySelector, comparer: { $0 == $1 })
@ -49,7 +49,7 @@ extension ObservableType {
- parameter comparer: Equality comparer for computed key values.
- returns: An observable sequence only containing the distinct contiguous elements, based on `comparer`, from the source sequence.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func distinctUntilChanged(_ comparer: (lhs: E, rhs: E) throws -> Bool)
-> Observable<E> {
return self.distinctUntilChanged({ $0 }, comparer: comparer)
@ -64,7 +64,7 @@ extension ObservableType {
- parameter comparer: Equality comparer for computed key values.
- returns: An observable sequence only containing the distinct contiguous elements, based on a computed key value and the comparer, from the source sequence.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func distinctUntilChanged<K>(_ keySelector: (E) throws -> K, comparer: (lhs: K, rhs: K) throws -> Bool)
-> Observable<E> {
return DistinctUntilChanged(source: self.asObservable(), selector: keySelector, comparer: comparer)
@ -83,7 +83,7 @@ extension ObservableType {
- parameter eventHandler: Action to invoke for each event in the observable sequence.
- returns: The source sequence with the side-effecting behavior applied.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func doOn(eventHandler: (Event<E>) throws -> Void)
-> Observable<E> {
return Do(source: self.asObservable(), eventHandler: eventHandler)
@ -99,7 +99,7 @@ extension ObservableType {
- parameter onCompleted: Action to invoke upon graceful termination of the observable sequence.
- returns: The source sequence with the side-effecting behavior applied.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func doOn(onNext: ((E) throws -> Void)? = nil, onError: ((ErrorProtocol) throws -> Void)? = nil, onCompleted: (() throws -> Void)? = nil)
-> Observable<E> {
return Do(source: self.asObservable()) { e in
@ -120,7 +120,7 @@ extension ObservableType {
- parameter onNext: Action to invoke for each element in the observable sequence.
- returns: The source sequence with the side-effecting behavior applied.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func doOnNext(onNext: ((E) throws -> Void))
-> Observable<E> {
return self.doOn(onNext: onNext)
@ -132,7 +132,7 @@ extension ObservableType {
- parameter onError: Action to invoke upon errored termination of the observable sequence.
- returns: The source sequence with the side-effecting behavior applied.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func doOnError(onError: ((ErrorProtocol) throws -> Void))
-> Observable<E> {
return self.doOn(onError: onError)
@ -144,7 +144,7 @@ extension ObservableType {
- parameter onCompleted: Action to invoke upon graceful termination of the observable sequence.
- returns: The source sequence with the side-effecting behavior applied.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func doOnCompleted(onCompleted: (() throws -> Void))
-> Observable<E> {
return self.doOn(onCompleted: onCompleted)
@ -163,7 +163,7 @@ extension ObservableType {
- parameter elements: Elements to prepend to the specified sequence.
- returns: The source sequence prepended with the specified values.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func startWith(_ elements: E ...)
-> Observable<E> {
return StartWith(source: self.asObservable(), elements: elements)
@ -183,7 +183,7 @@ extension ObservableType {
- returns: Observable sequence to repeat until it successfully terminates.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func retry() -> Observable<E> {
return CatchSequence(sources: InfiniteSequence(repeatedValue: self.asObservable()))
}
@ -198,7 +198,7 @@ extension ObservableType {
- parameter maxAttemptCount: Maximum number of times to repeat the sequence.
- returns: An observable sequence producing the elements of the given sequence repeatedly until it terminates successfully.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func retry(_ maxAttemptCount: Int)
-> Observable<E> {
return CatchSequence(sources: repeatElement(self.asObservable(), count: maxAttemptCount))
@ -213,7 +213,7 @@ extension ObservableType {
- parameter notificationHandler: A handler that is passed an observable sequence of errors raised by the source observable and returns and observable that either continues, completes or errors. This behavior is then applied to the source observable.
- returns: An observable sequence producing the elements of the given sequence repeatedly until it terminates successfully or is notified to error or complete.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func retryWhen<TriggerObservable: ObservableType, Error: ErrorProtocol>(_ notificationHandler: (Observable<Error>) -> TriggerObservable)
-> Observable<E> {
return RetryWhenSequence(sources: InfiniteSequence(repeatedValue: self.asObservable()), notificationHandler: notificationHandler)
@ -228,7 +228,7 @@ extension ObservableType {
- parameter notificationHandler: A handler that is passed an observable sequence of errors raised by the source observable and returns and observable that either continues, completes or errors. This behavior is then applied to the source observable.
- returns: An observable sequence producing the elements of the given sequence repeatedly until it terminates successfully or is notified to error or complete.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func retryWhen<TriggerObservable: ObservableType>(notificationHandler: (Observable<ErrorProtocol>) -> TriggerObservable)
-> Observable<E> {
return RetryWhenSequence(sources: InfiniteSequence(repeatedValue: self.asObservable()), notificationHandler: notificationHandler)
@ -250,7 +250,7 @@ extension ObservableType {
- parameter accumulator: An accumulator function to be invoked on each element.
- returns: An observable sequence containing the accumulated values.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func scan<A>(_ seed: A, accumulator: (A, E) throws -> A)
-> Observable<A> {
return Scan(source: self.asObservable(), seed: seed, accumulator: accumulator)

34
RxSwift/Observables/Observable+StandardSequenceOperators.swift
View File

@ -20,7 +20,7 @@ extension ObservableType {
- parameter predicate: A function to test each source element for a condition.
- returns: An observable sequence that contains elements from the input sequence that satisfy the condition.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func filter(_ predicate: (E) throws -> Bool)
-> Observable<E> {
return Filter(source: asObservable(), predicate: predicate)
@ -39,7 +39,7 @@ extension ObservableType {
- parameter predicate: A function to test each element for a condition.
- returns: An observable sequence that contains the elements from the input sequence that occur before the element at which the test no longer passes.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func takeWhile(_ predicate: (E) throws -> Bool)
-> Observable<E> {
return TakeWhile(source: asObservable(), predicate: predicate)
@ -55,7 +55,7 @@ extension ObservableType {
- parameter predicate: A function to test each element for a condition; the second parameter of the function represents the index of the source element.
- returns: An observable sequence that contains the elements from the input sequence that occur before the element at which the test no longer passes.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func takeWhileWithIndex(_ predicate: (E, Int) throws -> Bool)
-> Observable<E> {
return TakeWhile(source: asObservable(), predicate: predicate)
@ -74,7 +74,7 @@ extension ObservableType {
- parameter count: The number of elements to return.
- returns: An observable sequence that contains the specified number of elements from the start of the input sequence.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func take(_ count: Int)
-> Observable<E> {
if count == 0 {
@ -100,7 +100,7 @@ extension ObservableType {
- parameter count: Number of elements to take from the end of the source sequence.
- returns: An observable sequence containing the specified number of elements from the end of the source sequence.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func takeLast(_ count: Int)
-> Observable<E> {
return TakeLast(source: asObservable(), count: count)
@ -120,7 +120,7 @@ extension ObservableType {
- parameter count: The number of elements to skip before returning the remaining elements.
- returns: An observable sequence that contains the elements that occur after the specified index in the input sequence.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func skip(_ count: Int)
-> Observable<E> {
return SkipCount(source: asObservable(), count: count)
@ -139,7 +139,7 @@ extension ObservableType {
- parameter predicate: A function to test each element for a condition.
- returns: An observable sequence that contains the elements from the input sequence starting at the first element in the linear series that does not pass the test specified by predicate.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func skipWhile(_ predicate: (E) throws -> Bool) -> Observable<E> {
return SkipWhile(source: asObservable(), predicate: predicate)
}
@ -153,7 +153,7 @@ extension ObservableType {
- parameter predicate: A function to test each element for a condition; the second parameter of the function represents the index of the source element.
- returns: An observable sequence that contains the elements from the input sequence starting at the first element in the linear series that does not pass the test specified by predicate.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func skipWhileWithIndex(_ predicate: (E, Int) throws -> Bool) -> Observable<E> {
return SkipWhile(source: asObservable(), predicate: predicate)
}
@ -172,7 +172,7 @@ extension ObservableType {
- returns: An observable sequence whose elements are the result of invoking the transform function on each element of source.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func map<R>(_ selector: (E) throws -> R)
-> Observable<R> {
return self.asObservable().composeMap(selector)
@ -186,7 +186,7 @@ extension ObservableType {
- parameter selector: A transform function to apply to each source element; the second parameter of the function represents the index of the source element.
- returns: An observable sequence whose elements are the result of invoking the transform function on each element of source.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func mapWithIndex<R>(_ selector: (E, Int) throws -> R)
-> Observable<R> {
return MapWithIndex(source: asObservable(), selector: selector)
@ -205,7 +205,7 @@ extension ObservableType {
- parameter selector: A transform function to apply to each element.
- returns: An observable sequence whose elements are the result of invoking the one-to-many transform function on each element of the input sequence.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func flatMap<O: ObservableConvertibleType>(_ selector: (E) throws -> O)
-> Observable<O.E> {
return FlatMap(source: asObservable(), selector: selector)
@ -219,7 +219,7 @@ extension ObservableType {
- parameter selector: A transform function to apply to each element; the second parameter of the function represents the index of the source element.
- returns: An observable sequence whose elements are the result of invoking the one-to-many transform function on each element of the input sequence.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func flatMapWithIndex<O: ObservableConvertibleType>(_ selector: (E, Int) throws -> O)
-> Observable<O.E> {
return FlatMapWithIndex(source: asObservable(), selector: selector)
@ -239,7 +239,7 @@ extension ObservableType {
- parameter selector: A transform function to apply to element that was observed while no observable is executing in parallel.
- returns: An observable sequence whose elements are the result of invoking the one-to-many transform function on each element of the input sequence that was received while no other sequence was being calculated.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func flatMapFirst<O: ObservableConvertibleType>(_ selector: (E) throws -> O)
-> Observable<O.E> {
return FlatMapFirst(source: asObservable(), selector: selector)
@ -261,7 +261,7 @@ extension ObservableType {
- returns: An observable sequence whose elements are the result of invoking the transform function on each element of source producing an
Observable of Observable sequences and that at any point in time produces the elements of the most recent inner observable sequence that has been received.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func flatMapLatest<O: ObservableConvertibleType>(_ selector: (E) throws -> O)
-> Observable<O.E> {
return FlatMapLatest(source: asObservable(), selector: selector)
@ -280,7 +280,7 @@ extension ObservableType {
- parameter index: The index of the required item (starting from 0).
- returns: An observable sequence that emits the desired item as its own sole emission.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func elementAt(_ index: Int)
-> Observable<E> {
return ElementAt(source: asObservable(), index: index, throwOnEmpty: true)
@ -299,7 +299,7 @@ extension ObservableType {
- returns: An observable sequence that emits a single item or throws an exception if more (or none) of them are emitted.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func single()
-> Observable<E> {
return SingleAsync(source: asObservable())
@ -314,7 +314,7 @@ extension ObservableType {
- parameter predicate: A function to test each source element for a condition.
- returns: An observable sequence that emits a single item or throws an exception if more (or none) of them are emitted.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func single(_ predicate: (E) throws -> Bool)
-> Observable<E> {
return SingleAsync(source: asObservable(), predicate: predicate)

26
RxSwift/Observables/Observable+Time.swift
View File

@ -22,7 +22,7 @@ extension ObservableType {
- parameter scheduler: Scheduler to run the throttle timers and send events on.
- returns: The throttled sequence.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func throttle(_ dueTime: RxTimeInterval, scheduler: SchedulerType)
-> Observable<E> {
return Throttle(source: self.asObservable(), dueTime: dueTime, scheduler: scheduler)
@ -39,7 +39,7 @@ extension ObservableType {
- parameter scheduler: Scheduler to run the throttle timers and send events on.
- returns: The throttled sequence.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func debounce(_ dueTime: RxTimeInterval, scheduler: SchedulerType)
-> Observable<E> {
return Throttle(source: self.asObservable(), dueTime: dueTime, scheduler: scheduler)
@ -62,7 +62,7 @@ extension ObservableType {
- parameter sampler: Sampling tick sequence.
- returns: Sampled observable sequence.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func sample<O: ObservableType>(_ sampler: O)
-> Observable<E> {
return Sample(source: self.asObservable(), sampler: sampler.asObservable(), onlyNew: true)
@ -79,7 +79,7 @@ extension Observable where Element : SignedInteger {
- parameter scheduler: Scheduler to run the timer on.
- returns: An observable sequence that produces a value after each period.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public static func interval(_ period: RxTimeInterval, scheduler: SchedulerType)
-> Observable<E> {
return Timer(dueTime: period,
@ -102,7 +102,7 @@ extension Observable where Element: SignedInteger {
- parameter scheduler: Scheduler to run timers on.
- returns: An observable sequence that produces a value after due time has elapsed and then each period.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public static func timer(_ dueTime: RxTimeInterval, period: RxTimeInterval? = nil, scheduler: SchedulerType)
-> Observable<E> {
return Timer(
@ -126,7 +126,7 @@ extension ObservableType {
- parameter scheduler: Scheduler to run the timer on.
- returns: An observable sequence with the elements taken during the specified duration from the start of the source sequence.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func take(_ duration: RxTimeInterval, scheduler: SchedulerType)
-> Observable<E> {
return TakeTime(source: self.asObservable(), duration: duration, scheduler: scheduler)
@ -146,7 +146,7 @@ extension ObservableType {
- parameter scheduler: Scheduler to run the timer on.
- returns: An observable sequence with the elements skipped during the specified duration from the start of the source sequence.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func skip(_ duration: RxTimeInterval, scheduler: SchedulerType)
-> Observable<E> {
return SkipTime(source: self.asObservable(), duration: duration, scheduler: scheduler)
@ -164,7 +164,7 @@ extension ObservableType {
- returns: An observable sequence that skips all elements of the source sequence.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func ignoreElements()
-> Observable<E> {
return filter { _ -> Bool in
@ -186,7 +186,7 @@ extension ObservableType {
- parameter scheduler: Scheduler to run the subscription delay timer on.
- returns: Time-shifted sequence.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func delaySubscription(_ dueTime: RxTimeInterval, scheduler: SchedulerType)
-> Observable<E> {
return DelaySubscription(source: self.asObservable(), dueTime: dueTime, scheduler: scheduler)
@ -209,7 +209,7 @@ extension ObservableType {
- parameter scheduler: Scheduler to run buffering timers on.
- returns: An observable sequence of buffers.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func buffer(timeSpan: RxTimeInterval, count: Int, scheduler: SchedulerType)
-> Observable<[E]> {
return BufferTimeCount(source: self.asObservable(), timeSpan: timeSpan, count: count, scheduler: scheduler)
@ -230,7 +230,7 @@ extension ObservableType {
- parameter scheduler: Scheduler to run windowing timers on.
- returns: An observable sequence of windows (instances of `Observable`).
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func window(timeSpan: RxTimeInterval, count: Int, scheduler: SchedulerType)
-> Observable<Observable<E>> {
return WindowTimeCount(source: self.asObservable(), timeSpan: timeSpan, count: count, scheduler: scheduler)
@ -250,7 +250,7 @@ extension ObservableType {
- parameter scheduler: Scheduler to run the timeout timer on.
- returns: An observable sequence with a TimeoutError in case of a timeout.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func timeout(_ dueTime: RxTimeInterval, scheduler: SchedulerType)
-> Observable<E> {
return Timeout(source: self.asObservable(), dueTime: dueTime, other: Observable.error(RxError.timeout), scheduler: scheduler)
@ -266,7 +266,7 @@ extension ObservableType {
- parameter scheduler: Scheduler to run the timeout timer on.
- returns: The source sequence switching to the other sequence in case of a timeout.
*/
@warn_unused_result(message:"http://git.io/rxs.uo")
// @warn_unused_result(message:"http://git.io/rxs.uo")
public func timeout<O: ObservableConvertibleType where E == O.E>(_ dueTime: RxTimeInterval, other: O, scheduler: SchedulerType)
-> Observable<E> {
return Timeout(source: self.asObservable(), dueTime: dueTime, other: other.asObservable(), scheduler: scheduler)