zoukankan      html  css  js  c++  java
  • RxSwift源码与模式分析一:基本类

    封装、变换与处理

    // Represents a push style sequence.

    public protocol ObservableType : ObservableConvertibleType {

          func subscribe<O: ObserverType>(_ observer: O) -> Disposable where O.E == E

    }

    /// It represents a push style sequence.

    public class Observable<Element> : ObservableType {

        public typealias E = Element

        

        public func subscribe<O: ObserverType>(_ observer: O) -> Disposable where O.E == E {

            rxAbstractMethod()

        }

        

        public func asObservable() -> Observable<E> {

            return self

        }

        /// Optimizations for map operator

        internal func composeMap<R>(_ transform: @escaping (Element) throws -> R) -> Observable<R> {

            return _map(source: self, transform: transform)

        }

    }

    public protocol ObserverType {

        associatedtype E

        func on(_ event: Event<E>)

    }

    public enum Event<Element> {

        case next(Element)

        case error(Swift.Error)

        case completed

    }

    public struct Reactive<Base> {

        public let base: Base

        public init(_ base: Base) {

            self.base = base

        }

    }

    public struct Binder<Value>: ObserverType

  • 相关阅读:
    mysql 数据迁移方案
    tomcat:run 指定端口号
    idea open gradle project
    tomcat:run命令执行端口号
    域名代理
    stackoverflow慢问题
    chrome 添加 vue tools
    深度学习——结构化机器学习项目(学习策略2)[9]
    深度学习——超参数调试[7]
    深度学习——优化算法[6]
  • 原文地址:https://www.cnblogs.com/feng9exe/p/9004605.html
Copyright © 2011-2022 走看看