From e2edffc39da021d7940eac9df9a1a718bc8e2e66 Mon Sep 17 00:00:00 2001 From: Krunoslav Zaher Date: Fri, 8 Jul 2016 00:04:44 +0200 Subject: [PATCH] Fixes `@warn_unused_result(message: "http://git.io/rxs.ud")` warnings. --- Rx.xcodeproj/project.pbxproj | 4 +- .../ObservableConvertibleType+Blocking.swift | 2 +- RxCocoa/Common/CocoaUnits/ControlEvent.swift | 4 +- .../Common/CocoaUnits/ControlProperty.swift | 4 +- .../Driver/ControlEvent+Driver.swift | 2 +- .../Driver/ControlProperty+Driver.swift | 2 +- .../Driver/Driver+Operators+arity.swift | 28 +++++----- .../Driver/Driver+Operators+arity.tt | 4 +- .../CocoaUnits/Driver/Driver+Operators.swift | 52 +++++++++---------- .../Driver/Driver+Subscription.swift | 12 ++--- RxCocoa/Common/CocoaUnits/Driver/Driver.swift | 22 ++++---- .../ObservableConvertibleType+Driver.swift | 6 +-- .../CocoaUnits/Driver/Variable+Driver.swift | 2 +- RxCocoa/Common/Observable+Bind.swift | 10 ++-- .../Observables/NSNotificationCenter+Rx.swift | 2 +- .../NSObject+Rx+KVORepresentable.swift | 4 +- .../NSObject+Rx+RawRepresentable.swift | 4 +- RxCocoa/Common/Observables/NSObject+Rx.swift | 4 +- .../Common/Observables/NSURLSession+Rx.swift | 8 +-- RxSwift/Observable+Extensions.swift | 12 ++--- RxSwift/ObservableType.swift | 4 +- .../Implementations/CombineLatest+arity.swift | 14 ++--- .../Implementations/CombineLatest+arity.tt | 2 +- .../Implementations/Zip+arity.swift | 14 ++--- .../Observables/Implementations/Zip+arity.tt | 2 +- .../Observables/Observable+Aggregate.swift | 6 +-- RxSwift/Observables/Observable+Binding.swift | 18 +++---- .../Observables/Observable+Concurrency.swift | 4 +- RxSwift/Observables/Observable+Creation.swift | 26 +++++----- RxSwift/Observables/Observable+Debug.swift | 2 +- RxSwift/Observables/Observable+Multiple.swift | 32 ++++++------ RxSwift/Observables/Observable+Single.swift | 30 +++++------ ...Observable+StandardSequenceOperators.swift | 34 ++++++------ RxSwift/Observables/Observable+Time.swift | 26 +++++----- 34 files changed, 201 insertions(+), 201 deletions(-) diff --git a/Rx.xcodeproj/project.pbxproj b/Rx.xcodeproj/project.pbxproj index 3179d639..3f3bcc22 100644 --- a/Rx.xcodeproj/project.pbxproj +++ b/Rx.xcodeproj/project.pbxproj @@ -1444,7 +1444,7 @@ C8093C641B8A72BE0088E94D /* Event.swift */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.swift; path = Event.swift; sourceTree = ""; }; C8093C651B8A72BE0088E94D /* ImmediateSchedulerType.swift */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.swift; path = ImmediateSchedulerType.swift; sourceTree = ""; }; C8093C661B8A72BE0088E94D /* Info.plist */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = text.plist.xml; path = Info.plist; sourceTree = ""; }; - C8093C671B8A72BE0088E94D /* Observable+Extensions.swift */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.swift; path = "Observable+Extensions.swift"; sourceTree = ""; }; + C8093C671B8A72BE0088E94D /* Observable+Extensions.swift */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.swift; lineEnding = 0; path = "Observable+Extensions.swift"; sourceTree = ""; xcLanguageSpecificationIdentifier = xcode.lang.swift; }; C8093C681B8A72BE0088E94D /* Observable.swift */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.swift; path = Observable.swift; sourceTree = ""; }; C8093C6B1B8A72BE0088E94D /* Amb.swift */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.swift; path = Amb.swift; sourceTree = ""; }; C8093C6E1B8A72BE0088E94D /* Catch.swift */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.swift; path = Catch.swift; sourceTree = ""; }; @@ -1539,7 +1539,7 @@ C8093ECB1B8A732E0088E94D /* RxCocoa.h */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.c.h; path = RxCocoa.h; sourceTree = ""; }; C8093F581B8A73A20088E94D /* ObservableConvertibleType+Blocking.swift */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.swift; path = "ObservableConvertibleType+Blocking.swift"; sourceTree = ""; xcLanguageSpecificationIdentifier = xcode.lang.swift; }; C8093F591B8A73A20088E94D /* README.md */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = net.daringfireball.markdown; path = README.md; sourceTree = ""; }; - C80D338E1B91EF9E0014629D /* Observable+Bind.swift */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.swift; path = "Observable+Bind.swift"; sourceTree = ""; }; + C80D338E1B91EF9E0014629D /* Observable+Bind.swift */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.swift; lineEnding = 0; path = "Observable+Bind.swift"; sourceTree = ""; xcLanguageSpecificationIdentifier = xcode.lang.swift; }; C80D33931B922FB00014629D /* ControlEvent.swift */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.swift; path = ControlEvent.swift; sourceTree = ""; }; C80D33941B922FB00014629D /* ControlProperty.swift */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.swift; lineEnding = 0; path = ControlProperty.swift; sourceTree = ""; xcLanguageSpecificationIdentifier = xcode.lang.swift; }; C80D342D1B9245A40014629D /* CombineLatest+CollectionType.swift */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.swift; lineEnding = 0; path = "CombineLatest+CollectionType.swift"; sourceTree = ""; xcLanguageSpecificationIdentifier = xcode.lang.swift; }; diff --git a/RxBlocking/ObservableConvertibleType+Blocking.swift b/RxBlocking/ObservableConvertibleType+Blocking.swift index 4268fbd4..79a08d76 100644 --- a/RxBlocking/ObservableConvertibleType+Blocking.swift +++ b/RxBlocking/ObservableConvertibleType+Blocking.swift @@ -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 { return BlockingObservable(source: self.asObservable()) } diff --git a/RxCocoa/Common/CocoaUnits/ControlEvent.swift b/RxCocoa/Common/CocoaUnits/ControlEvent.swift index 41212931..a92b0170 100644 --- a/RxCocoa/Common/CocoaUnits/ControlEvent.swift +++ b/RxCocoa/Common/CocoaUnits/ControlEvent.swift @@ -71,7 +71,7 @@ public struct ControlEvent : 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 { return _events } @@ -79,7 +79,7 @@ public struct ControlEvent : 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 { return self } diff --git a/RxCocoa/Common/CocoaUnits/ControlProperty.swift b/RxCocoa/Common/CocoaUnits/ControlProperty.swift index cdbeca1a..e6223913 100644 --- a/RxCocoa/Common/CocoaUnits/ControlProperty.swift +++ b/RxCocoa/Common/CocoaUnits/ControlProperty.swift @@ -77,7 +77,7 @@ public struct ControlProperty : 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 { return _values } @@ -85,7 +85,7 @@ public struct ControlProperty : 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 { return self } diff --git a/RxCocoa/Common/CocoaUnits/Driver/ControlEvent+Driver.swift b/RxCocoa/Common/CocoaUnits/Driver/ControlEvent+Driver.swift index 6bbf0065..61a25c97 100644 --- a/RxCocoa/Common/CocoaUnits/Driver/ControlEvent+Driver.swift +++ b/RxCocoa/Common/CocoaUnits/Driver/ControlEvent+Driver.swift @@ -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 { return self.asDriver { (error) -> Driver in #if DEBUG diff --git a/RxCocoa/Common/CocoaUnits/Driver/ControlProperty+Driver.swift b/RxCocoa/Common/CocoaUnits/Driver/ControlProperty+Driver.swift index 0baef68b..c7521564 100644 --- a/RxCocoa/Common/CocoaUnits/Driver/ControlProperty+Driver.swift +++ b/RxCocoa/Common/CocoaUnits/Driver/ControlProperty+Driver.swift @@ -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 { return self.asDriver { (error) -> Driver in #if DEBUG diff --git a/RxCocoa/Common/CocoaUnits/Driver/Driver+Operators+arity.swift b/RxCocoa/Common/CocoaUnits/Driver/Driver+Operators+arity.swift index 31589e76..22cf0374 100644 --- a/RxCocoa/Common/CocoaUnits/Driver/Driver+Operators+arity.swift +++ b/RxCocoa/Common/CocoaUnits/Driver/Driver+Operators+arity.swift @@ -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 (_ source1: O1, _ source2: O2, resultSelector: (O1.E, O2.E) throws -> E) -> Driver { @@ -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 (_ source1: O1, _ source2: O2, resultSelector: (O1.E, O2.E) throws -> E) -> Driver { @@ -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 (_ source1: O1, _ source2: O2, _ source3: O3, resultSelector: (O1.E, O2.E, O3.E) throws -> E) -> Driver { @@ -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 (_ source1: O1, _ source2: O2, _ source3: O3, resultSelector: (O1.E, O2.E, O3.E) throws -> E) -> Driver { @@ -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 (_ source1: O1, _ source2: O2, _ source3: O3, _ source4: O4, resultSelector: (O1.E, O2.E, O3.E, O4.E) throws -> E) -> Driver { @@ -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 (_ source1: O1, _ source2: O2, _ source3: O3, _ source4: O4, resultSelector: (O1.E, O2.E, O3.E, O4.E) throws -> E) -> Driver { @@ -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 (_ source1: O1, _ source2: O2, _ source3: O3, _ source4: O4, _ source5: O5, resultSelector: (O1.E, O2.E, O3.E, O4.E, O5.E) throws -> E) -> Driver { @@ -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 (_ source1: O1, _ source2: O2, _ source3: O3, _ source4: O4, _ source5: O5, resultSelector: (O1.E, O2.E, O3.E, O4.E, O5.E) throws -> E) -> Driver { @@ -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 (_ 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 { @@ -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 (_ 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 { @@ -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 (_ 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 { @@ -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 (_ 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 { @@ -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 (_ 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 { @@ -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 (_ 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 { diff --git a/RxCocoa/Common/CocoaUnits/Driver/Driver+Operators+arity.tt b/RxCocoa/Common/CocoaUnits/Driver/Driver+Operators+arity.tt index 9b7ea8f5..3d70ab1d 100644 --- a/RxCocoa/Common/CocoaUnits/Driver/Driver+Operators+arity.tt +++ b/RxCocoa/Common/CocoaUnits/Driver/Driver+Operators+arity.tt @@ -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 { @@ -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 { diff --git a/RxCocoa/Common/CocoaUnits/Driver/Driver+Operators.swift b/RxCocoa/Common/CocoaUnits/Driver/Driver+Operators.swift index dfacfc54..6063cb28 100644 --- a/RxCocoa/Common/CocoaUnits/Driver/Driver+Operators.swift +++ b/RxCocoa/Common/CocoaUnits/Driver/Driver+Operators.swift @@ -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(_ selector: (E) -> R) -> Driver { 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 { 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 { let source: Observable = 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(_ selector: (E) -> Driver) -> Driver { let source: Observable = 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(_ selector: (E) -> Driver) -> Driver { let source: Observable = 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) -> Void) -> Driver { 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 { 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 { 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 { 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 { 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 { 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(_ keySelector: (E) -> K) -> Driver { 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 { 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(_ keySelector: (E) -> K, comparer: (lhs: K, rhs: K) -> Bool) -> Driver { 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(_ selector: (E) -> Driver) -> Driver { 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 { 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 { 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 { 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 { 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(_ seed: A, accumulator: (A, E) -> A) -> Driver { 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 { 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 { 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(_ resultSelector: ([Generator.Element.E]) throws -> R) -> Driver { let source = self.map { $0.asDriver().asObservable() }.zip(resultSelector: resultSelector) return Driver(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(_ resultSelector: ([Generator.Element.E]) throws -> R) -> Driver { let source = self.map { $0.asDriver().asObservable() }.combineLatest(resultSelector: resultSelector) return Driver(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 { 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 { let source = self.asObservable() diff --git a/RxCocoa/Common/CocoaUnits/Driver/Driver+Subscription.swift b/RxCocoa/Common/CocoaUnits/Driver/Driver+Subscription.swift index 7adfa69a..9f15a343 100644 --- a/RxCocoa/Common/CocoaUnits/Driver/Driver+Subscription.swift +++ b/RxCocoa/Common/CocoaUnits/Driver/Driver+Subscription.swift @@ -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(_ 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) -> 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(_ transformation: (Observable) -> 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(_ with: (Observable) -> (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) diff --git a/RxCocoa/Common/CocoaUnits/Driver/Driver.swift b/RxCocoa/Common/CocoaUnits/Driver/Driver.swift index 06f447b7..0844fe1d 100644 --- a/RxCocoa/Common/CocoaUnits/Driver/Driver.swift +++ b/RxCocoa/Common/CocoaUnits/Driver/Driver.swift @@ -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 } extension DriverConvertibleType { - @warn_unused_result(message:"http://git.io/rxs.uo") + // @warn_unused_result(message:"http://git.io/rxs.uo") public func asObservable() -> Observable { return asDriver().asObservable() } @@ -75,7 +75,7 @@ public struct Driver : 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 { return _source } @@ -83,7 +83,7 @@ public struct Driver : 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 { 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 { 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 { 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 { 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) -> Driver { 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 { 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 { 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 { return Driver(Observable.timer(dueTime, period: period, scheduler: driverObserveOnScheduler)) diff --git a/RxCocoa/Common/CocoaUnits/Driver/ObservableConvertibleType+Driver.swift b/RxCocoa/Common/CocoaUnits/Driver/ObservableConvertibleType+Driver.swift index 02f50cbe..4ccfc56e 100644 --- a/RxCocoa/Common/CocoaUnits/Driver/ObservableConvertibleType+Driver.swift +++ b/RxCocoa/Common/CocoaUnits/Driver/ObservableConvertibleType+Driver.swift @@ -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 { 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) -> Driver { 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) -> Driver { let source = self .asObservable() diff --git a/RxCocoa/Common/CocoaUnits/Driver/Variable+Driver.swift b/RxCocoa/Common/CocoaUnits/Driver/Variable+Driver.swift index 311ab2fe..9e7cfd27 100644 --- a/RxCocoa/Common/CocoaUnits/Driver/Variable+Driver.swift +++ b/RxCocoa/Common/CocoaUnits/Driver/Variable+Driver.swift @@ -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 { let source = self.asObservable() .observeOn(driverObserveOnScheduler) diff --git a/RxCocoa/Common/Observable+Bind.swift b/RxCocoa/Common/Observable+Bind.swift index 2e1582c7..0c7db3b7 100644 --- a/RxCocoa/Common/Observable+Bind.swift +++ b/RxCocoa/Common/Observable+Bind.swift @@ -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(_ 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) -> 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(_ 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(_ 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)" diff --git a/RxCocoa/Common/Observables/NSNotificationCenter+Rx.swift b/RxCocoa/Common/Observables/NSNotificationCenter+Rx.swift index 523b6b70..8a87cfe4 100644 --- a/RxCocoa/Common/Observables/NSNotificationCenter+Rx.swift +++ b/RxCocoa/Common/Observables/NSNotificationCenter+Rx.swift @@ -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 { return Observable.create { [weak object] observer in let nsObserver = self.addObserver(forName: name, object: object, queue: nil) { notification in diff --git a/RxCocoa/Common/Observables/NSObject+Rx+KVORepresentable.swift b/RxCocoa/Common/Observables/NSObject+Rx+KVORepresentable.swift index 2c279109..aba143ab 100644 --- a/RxCocoa/Common/Observables/NSObject+Rx+KVORepresentable.swift +++ b/RxCocoa/Common/Observables/NSObject+Rx+KVORepresentable.swift @@ -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(_ type: E.Type, _ keyPath: String, options: NSKeyValueObservingOptions = [.new, .initial], retainSelf: Bool = true) -> Observable { 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(_ type: E.Type, _ keyPath: String, options: NSKeyValueObservingOptions = [.new, .initial]) -> Observable { return rx_observeWeakly(E.KVOType.self, keyPath, options: options) .map(E.init) diff --git a/RxCocoa/Common/Observables/NSObject+Rx+RawRepresentable.swift b/RxCocoa/Common/Observables/NSObject+Rx+RawRepresentable.swift index e53f8907..20c89f1e 100644 --- a/RxCocoa/Common/Observables/NSObject+Rx+RawRepresentable.swift +++ b/RxCocoa/Common/Observables/NSObject+Rx+RawRepresentable.swift @@ -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(_ type: E.Type, _ keyPath: String, options: NSKeyValueObservingOptions = [.new, .initial], retainSelf: Bool = true) -> Observable { 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(_ type: E.Type, _ keyPath: String, options: NSKeyValueObservingOptions = [.new, .initial]) -> Observable { return rx_observeWeakly(E.RawValue.KVOType.self, keyPath, options: options) .map(E.init) diff --git a/RxCocoa/Common/Observables/NSObject+Rx.swift b/RxCocoa/Common/Observables/NSObject+Rx.swift index c3c92836..3539aa3b 100644 --- a/RxCocoa/Common/Observables/NSObject+Rx.swift +++ b/RxCocoa/Common/Observables/NSObject+Rx.swift @@ -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(_ type: E.Type, _ keyPath: String, options: NSKeyValueObservingOptions = [.new, .initial], retainSelf: Bool = true) -> Observable { 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(_ type: E.Type, _ keyPath: String, options: NSKeyValueObservingOptions = [.new, .initial]) -> Observable { return observeWeaklyKeyPathFor(self, keyPath: keyPath, options: options) .map { n in diff --git a/RxCocoa/Common/Observables/NSURLSession+Rx.swift b/RxCocoa/Common/Observables/NSURLSession+Rx.swift index 9d4e0ef1..36e8b914 100644 --- a/RxCocoa/Common/Observables/NSURLSession+Rx.swift +++ b/RxCocoa/Common/Observables/NSURLSession+Rx.swift @@ -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 { 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 { 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 { return rx_JSON(URLRequest(url: URL)) } diff --git a/RxSwift/Observable+Extensions.swift b/RxSwift/Observable+Extensions.swift index ce388bf9..09dfe602 100644 --- a/RxSwift/Observable+Extensions.swift +++ b/RxSwift/Observable+Extensions.swift @@ -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) -> 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 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 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 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(_ observer: O) -> Disposable { return self.asObservable().subscribe(observer) } diff --git a/RxSwift/ObservableType.swift b/RxSwift/ObservableType.swift index ae097ef6..5e5f7a9d 100644 --- a/RxSwift/ObservableType.swift +++ b/RxSwift/ObservableType.swift @@ -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(_ 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 { // temporary workaround //return Observable.create(subscribe: self.subscribe) diff --git a/RxSwift/Observables/Implementations/CombineLatest+arity.swift b/RxSwift/Observables/Implementations/CombineLatest+arity.swift index e90d96c1..9ac0ebe2 100644 --- a/RxSwift/Observables/Implementations/CombineLatest+arity.swift +++ b/RxSwift/Observables/Implementations/CombineLatest+arity.swift @@ -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 (_ source1: O1, _ source2: O2, resultSelector: (O1.E, O2.E) throws -> E) -> Observable { @@ -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 (_ source1: O1, _ source2: O2, _ source3: O3, resultSelector: (O1.E, O2.E, O3.E) throws -> E) -> Observable { @@ -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 (_ source1: O1, _ source2: O2, _ source3: O3, _ source4: O4, resultSelector: (O1.E, O2.E, O3.E, O4.E) throws -> E) -> Observable { @@ -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 (_ source1: O1, _ source2: O2, _ source3: O3, _ source4: O4, _ source5: O5, resultSelector: (O1.E, O2.E, O3.E, O4.E, O5.E) throws -> E) -> Observable { @@ -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 (_ 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 { @@ -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 (_ 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 { @@ -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 (_ 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 { diff --git a/RxSwift/Observables/Implementations/CombineLatest+arity.tt b/RxSwift/Observables/Implementations/CombineLatest+arity.tt index 8f0e88d8..2ba4550f 100644 --- a/RxSwift/Observables/Implementations/CombineLatest+arity.tt +++ b/RxSwift/Observables/Implementations/CombineLatest+arity.tt @@ -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 { diff --git a/RxSwift/Observables/Implementations/Zip+arity.swift b/RxSwift/Observables/Implementations/Zip+arity.swift index 6d7c1e2c..00cacab4 100644 --- a/RxSwift/Observables/Implementations/Zip+arity.swift +++ b/RxSwift/Observables/Implementations/Zip+arity.swift @@ -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 (_ source1: O1, _ source2: O2, resultSelector: (O1.E, O2.E) throws -> E) -> Observable { @@ -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 (_ source1: O1, _ source2: O2, _ source3: O3, resultSelector: (O1.E, O2.E, O3.E) throws -> E) -> Observable { @@ -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 (_ source1: O1, _ source2: O2, _ source3: O3, _ source4: O4, resultSelector: (O1.E, O2.E, O3.E, O4.E) throws -> E) -> Observable { @@ -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 (_ source1: O1, _ source2: O2, _ source3: O3, _ source4: O4, _ source5: O5, resultSelector: (O1.E, O2.E, O3.E, O4.E, O5.E) throws -> E) -> Observable { @@ -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 (_ 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 { @@ -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 (_ 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 { @@ -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 (_ 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 { diff --git a/RxSwift/Observables/Implementations/Zip+arity.tt b/RxSwift/Observables/Implementations/Zip+arity.tt index 8ea7d4e1..3ed2622e 100644 --- a/RxSwift/Observables/Implementations/Zip+arity.tt +++ b/RxSwift/Observables/Implementations/Zip+arity.tt @@ -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 { diff --git a/RxSwift/Observables/Observable+Aggregate.swift b/RxSwift/Observables/Observable+Aggregate.swift index b1babb79..8aafaf63 100644 --- a/RxSwift/Observables/Observable+Aggregate.swift +++ b/RxSwift/Observables/Observable+Aggregate.swift @@ -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(_ seed: A, accumulator: (A, E) throws -> A, mapResult: (A) throws -> R) -> Observable { 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(_ seed: A, accumulator: (A, E) throws -> A) -> Observable { 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()) diff --git a/RxSwift/Observables/Observable+Binding.swift b/RxSwift/Observables/Observable+Binding.swift index 1db7db2d..134825a7 100644 --- a/RxSwift/Observables/Observable+Binding.swift +++ b/RxSwift/Observables/Observable+Binding.swift @@ -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(_ subject: S) -> ConnectableObservable { 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(_ subjectSelector: () throws -> S, selector: (Observable) throws -> Observable) -> Observable { 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 { 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 { 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 { 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 { 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 { 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 { 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 { return ShareReplay1WhileConnected(source: self.asObservable()) diff --git a/RxSwift/Observables/Observable+Concurrency.swift b/RxSwift/Observables/Observable+Concurrency.swift index e44c4f84..1ece7d82 100644 --- a/RxSwift/Observables/Observable+Concurrency.swift +++ b/RxSwift/Observables/Observable+Concurrency.swift @@ -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 { 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 { return SubscribeOn(source: self, scheduler: scheduler) diff --git a/RxSwift/Observables/Observable+Creation.swift b/RxSwift/Observables/Observable+Creation.swift index 946c2eea..5b2f9385 100644 --- a/RxSwift/Observables/Observable+Creation.swift +++ b/RxSwift/Observables/Observable+Creation.swift @@ -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) -> Disposable) -> Observable { 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 { return Empty() } @@ -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 { 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 { 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 { 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 { 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) -> Observable { 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 { 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 { 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(_ resourceFactory: () throws -> R, observableFactory: (R) throws -> Observable) -> Observable { 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 { return RangeProducer(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 { 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 { return ObservableSequence(elements: self, scheduler: scheduler) } diff --git a/RxSwift/Observables/Observable+Debug.swift b/RxSwift/Observables/Observable+Debug.swift index 149ed352..331940c5 100644 --- a/RxSwift/Observables/Observable+Debug.swift +++ b/RxSwift/Observables/Observable+Debug.swift @@ -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 { return Debug(source: self.asObservable(), identifier: identifier, file: file, line: line, function: function) diff --git a/RxSwift/Observables/Observable+Multiple.swift b/RxSwift/Observables/Observable+Multiple.swift index c194772e..9a646de5 100644 --- a/RxSwift/Observables/Observable+Multiple.swift +++ b/RxSwift/Observables/Observable+Multiple.swift @@ -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(resultSelector: ([Generator.Element.E]) throws -> R) -> Observable { 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(resultSelector: ([Generator.Element.E]) throws -> R) -> Observable { 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 { 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(_ second: O) -> Observable { 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 { 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 { 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 { 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 { 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 { 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) -> Observable { 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 { 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 { 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(_ other: O) -> Observable { 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(_ other: O) -> Observable { 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 (_ right: O2) -> Observable { @@ -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 { return self.reduce(Observable.never()) { a, o in diff --git a/RxSwift/Observables/Observable+Single.swift b/RxSwift/Observables/Observable+Single.swift index 1627e0b4..784fd4a0 100644 --- a/RxSwift/Observables/Observable+Single.swift +++ b/RxSwift/Observables/Observable+Single.swift @@ -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 { 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(_ keySelector: (E) throws -> K) -> Observable { 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 { 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(_ keySelector: (E) throws -> K, comparer: (lhs: K, rhs: K) throws -> Bool) -> Observable { 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) throws -> Void) -> Observable { 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 { 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 { 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 { 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 { 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 { 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 { 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 { 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(_ notificationHandler: (Observable) -> TriggerObservable) -> Observable { 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(notificationHandler: (Observable) -> TriggerObservable) -> Observable { 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(_ seed: A, accumulator: (A, E) throws -> A) -> Observable { return Scan(source: self.asObservable(), seed: seed, accumulator: accumulator) diff --git a/RxSwift/Observables/Observable+StandardSequenceOperators.swift b/RxSwift/Observables/Observable+StandardSequenceOperators.swift index de0f0dc9..6bfb5055 100644 --- a/RxSwift/Observables/Observable+StandardSequenceOperators.swift +++ b/RxSwift/Observables/Observable+StandardSequenceOperators.swift @@ -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 { 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 { 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 { 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 { 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 { 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 { 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 { 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 { 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(_ selector: (E) throws -> R) -> Observable { 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(_ selector: (E, Int) throws -> R) -> Observable { 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(_ selector: (E) throws -> O) -> Observable { 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(_ selector: (E, Int) throws -> O) -> Observable { 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(_ selector: (E) throws -> O) -> Observable { 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(_ selector: (E) throws -> O) -> Observable { 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 { 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 { 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 { return SingleAsync(source: asObservable(), predicate: predicate) diff --git a/RxSwift/Observables/Observable+Time.swift b/RxSwift/Observables/Observable+Time.swift index 428ab594..2b604037 100644 --- a/RxSwift/Observables/Observable+Time.swift +++ b/RxSwift/Observables/Observable+Time.swift @@ -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 { 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 { 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(_ sampler: O) -> Observable { 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 { 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 { 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 { 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 { 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 { 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 { 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> { 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 { 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(_ dueTime: RxTimeInterval, other: O, scheduler: SchedulerType) -> Observable { return Timeout(source: self.asObservable(), dueTime: dueTime, other: other.asObservable(), scheduler: scheduler)