@@ -25,17 +25,14 @@ public extension PrimitiveSequenceType where Self: ObservableConvertibleType, Se
2525 -> Disposable where A. Payload == Self . Element {
2626 let subscription = subscribe (
2727 onSuccess: { payload in
28- // swiftlint:disable:next explicit_init
2928 let action = A ( promise: . value( payload) )
3029 dispatcher. dispatch ( action, mode: mode)
3130 } ,
3231 onError: { error in
3332 var action : A
3433 if let errorPayload = errorPayload {
35- // swiftlint:disable:next explicit_init
3634 action = A ( promise: . value( errorPayload) )
3735 } else {
38- // swiftlint:disable:next explicit_init
3936 action = A ( promise: . error( error) )
4037 }
4138 dispatcher. dispatch ( action, mode: mode)
@@ -52,17 +49,14 @@ public extension PrimitiveSequenceType where Self: ObservableConvertibleType, Se
5249 -> Disposable where A. Payload == Self . Element {
5350 let subscription = subscribe (
5451 onSuccess: { payload in
55- // swiftlint:disable:next explicit_init
5652 let action = A ( promise: [ key: . value( payload) ] )
5753 dispatcher. dispatch ( action, mode: mode)
5854 } ,
5955 onError: { error in
6056 var action : A
6157 if let errorPayload = errorPayload {
62- // swiftlint:disable:next explicit_init
6358 action = A ( promise: [ key: . value( errorPayload) ] )
6459 } else {
65- // swiftlint:disable:next explicit_init
6660 action = A ( promise: [ key: . error( error) ] )
6761 }
6862 dispatcher. dispatch ( action, mode: mode)
@@ -77,17 +71,14 @@ public extension PrimitiveSequenceType where Self: ObservableConvertibleType, Se
7771 return Single < A > . create { single in
7872 let subscription = self . subscribe (
7973 onSuccess: { payload in
80- // swiftlint:disable:next explicit_init
8174 let action = A ( promise: . value( payload) )
8275 single ( . success( action) )
8376 } ,
8477 onError: { error in
8578 var action : A
8679 if let errorPayload = errorPayload {
87- // swiftlint:disable:next explicit_init
8880 action = A ( promise: . value( errorPayload) )
8981 } else {
90- // swiftlint:disable:next explicit_init
9182 action = A ( promise: . error( error) )
9283 }
9384 single ( . success( action) )
@@ -106,11 +97,9 @@ public extension PrimitiveSequenceType where Trait == CompletableTrait, Element
10697 let subscription = subscribe { completable in
10798 switch completable {
10899 case . completed:
109- // swiftlint:disable:next explicit_init
110100 let action = A ( promise: . never( ) )
111101 dispatcher. dispatch ( action, mode: mode)
112102 case let . error( error) :
113- // swiftlint:disable:next explicit_init
114103 let action = A ( promise: . error( error) )
115104 dispatcher. dispatch ( action, mode: mode)
116105 }
0 commit comments