rename observable mappable method
This commit is contained in:
parent
3edfe50164
commit
32eefa77a6
|
|
@ -54,7 +54,7 @@ public extension Reactive where Base: DataRequest {
|
|||
.observeOn(SerialDispatchQueueScheduler(queue: mappingQueue, internalSerialQueueName: mappingQueue.label))
|
||||
.tryMapObservableResult { response, value in
|
||||
let json = try JSONSerialization.jsonObject(with: value, options: [])
|
||||
return T.createFrom(decoder: decoder, jsonObject: json)
|
||||
return T.create(from: json, with: decoder)
|
||||
.map { (response, $0) }
|
||||
}
|
||||
}
|
||||
|
|
|
|||
|
|
@ -27,6 +27,6 @@ public protocol ObservableMappable {
|
|||
|
||||
associatedtype ModelType: Decodable
|
||||
|
||||
static func createFrom(decoder: JSONDecoder, jsonObject: Any) -> Observable<ModelType>
|
||||
static func create(from jsonObject: Any, with decoder: JSONDecoder) -> Observable<ModelType>
|
||||
|
||||
}
|
||||
|
|
|
|||
|
|
@ -47,7 +47,7 @@ extension Album: Equatable {
|
|||
|
||||
extension Album: ObservableMappable {
|
||||
|
||||
static func createFrom(decoder: JSONDecoder, jsonObject: Any) -> Observable<Album> {
|
||||
static func create(from jsonObject: Any, with decoder: JSONDecoder) -> Observable<Album> {
|
||||
return Observable.deferredJust {
|
||||
let data = try JSONSerialization.data(withJSONObject: jsonObject, options: [])
|
||||
return try decoder.decode(Album.self, from: data)
|
||||
|
|
|
|||
|
|
@ -30,7 +30,7 @@ struct AlbumContainer: Decodable {
|
|||
|
||||
extension AlbumContainer: ObservableMappable {
|
||||
|
||||
static func createFrom(decoder: JSONDecoder, jsonObject: Any) -> Observable<AlbumContainer> {
|
||||
static func create(from jsonObject: Any, with decoder: JSONDecoder) -> Observable<AlbumContainer> {
|
||||
return Observable.deferredJust { try cast(jsonObject) as [Any] }
|
||||
.flatMap {
|
||||
$0.concurrentRxMap { json -> Album in
|
||||
|
|
|
|||
|
|
@ -41,7 +41,7 @@ struct Post: Decodable {
|
|||
|
||||
extension Post: ObservableMappable {
|
||||
|
||||
static func createFrom(decoder: JSONDecoder, jsonObject: Any) -> Observable<Post> {
|
||||
static func create(from jsonObject: Any, with decoder: JSONDecoder) -> Observable<Post> {
|
||||
return Observable.deferredJust {
|
||||
let data = try JSONSerialization.data(withJSONObject: jsonObject, options: [])
|
||||
return try decoder.decode(Post.self, from: data)
|
||||
|
|
|
|||
Loading…
Reference in New Issue