• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    公众号

TypeScript base.StreamAdapter类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了TypeScript中@cycle/base.StreamAdapter的典型用法代码示例。如果您正苦于以下问题:TypeScript StreamAdapter类的具体用法?TypeScript StreamAdapter怎么用?TypeScript StreamAdapter使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



在下文中一共展示了StreamAdapter类的9个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的TypeScript代码示例。

示例1: constructor

 constructor(private _streamAdapter: StreamAdapter,
             private _mockConfig: MockConfig) {
   if (_mockConfig.elements) {
     this._elements = _mockConfig.elements;
   } else {
     this._elements = _streamAdapter.adapt(xs.empty(), xsSA.streamSubscribe);
   }
 }
开发者ID:E-LLP,项目名称:dom,代码行数:8,代码来源:mockDOMSource.ts


示例2: convertStream

export function convertStream (stream: any, sourceSA: StreamAdapter, targetSA: StreamAdapter) {
  return targetSA.isValidStream(stream)
    ? stream
    : targetSA.adapt(stream, sourceSA.streamSubscribe)
}
开发者ID:goodmind,项目名称:cycle-telegram,代码行数:5,代码来源:index.ts


示例3: constructor

 constructor(html$: Stream<string>,
             private runSA: StreamAdapter) {
   this._html$ = html$;
   this._empty$ = runSA.adapt(xs.empty(), xsSA.streamSubscribe);
 }
开发者ID:DrUNE,项目名称:cyclejs,代码行数:5,代码来源:HTMLSource.ts


示例4: Error

 proxyStream.proxy = (target: Stream) => {
   if (!target || !adapter.isValidStream(target)){
     throw new Error('You should provide a valid target stream to proxy')
   }
   if (targetStream){
     throw new Error('You may provide only one target stream to proxy')
   }
   targetStream = composeFn(target)
   proxyStream.__proxyRefs = 0      
   return adapter.adapt({}, (_: any, observer: Observer<any>) => {        
     let dispose = adapter.streamSubscribe(target, observer)        
     if (proxyStream.__proxyRefs++ === 0) {          
       proxyDispose = adapter.streamSubscribe(
         targetStream, proxyObserver
       )          
     }
     return () => {
       dispose()
       if (--proxyStream.__proxyRefs === 0) {
         proxyDispose()
         proxyObserver.complete()
         if (proxyStream.__onProxyDispose) {
           proxyStream.__onProxyDispose()
         }
       }
     }
   })
 }
开发者ID:whitecolor,项目名称:cycle-circular,代码行数:28,代码来源:index.ts


示例5: function

    return function (sources: any, ...rest: any[]) {
      let circular$ = sources[circularName] = proxy()
      let sinks = dataflow(sources, ...rest) as any

      const proxyStreams: any = {}
      const proxiedSinks: any = {}

      const disposeCircular = adapter.streamSubscribe(
        circular$.proxy(sinks[circularName]), {
          next: () => { }, error: () => { }, complete: () => { }
        }
      )

      const checkAllDisposed = () => {
        let disposed = true
        for (const key in proxyStreams) {
          if (proxyStreams[key].__proxyRefs) {
            disposed = false
          }
        }
        if (disposed) {
          disposeCircular()
        }
      }

      for (const key in sinks) {
        // TODO: decide if we we need 
        // to remove circular$ stream from sinks 
        //if (key === circularName) return
        const sink = sinks[key]
        if (sink && adapter.isValidStream(sink)) {
          proxyStreams[key] = proxy()
          proxiedSinks[key] = proxyStreams[key].proxy(sink)
          proxyStreams[key].__onProxyDispose = checkAllDisposed
          // TODO: probably can use proxy completition
          // if proxy can be subscribed once?
          // adapter.streamSubscribe(proxyStreams[key], {
          //   next: () => { },
          //   error: () => { },
          //   complete: () => { console.log(key + 'completed') }
          // })
        } else {
          proxiedSinks[key] = sink
        }
      }
      return proxiedSinks
    }
开发者ID:whitecolor,项目名称:cycle-circular,代码行数:47,代码来源:index.ts


示例6: RouterSource

  path(pathname: Pathname): RouterSource {
    const scopedNamespace = this._namespace.concat(util.splitPath(pathname));
    const scopedHistory$ = this._runSA.remember(this._history$
      .filter(({pathname: _path}: Location) => isStrictlyInScope(scopedNamespace, _path)));

    const createHref = this._createHref;
    return new RouterSource(scopedHistory$, scopedNamespace, createHref, this._runSA);
  }
开发者ID:lius,项目名称:cyclic-router,代码行数:8,代码来源:RouterSource.ts


示例7: return

 return adapter.adapt({}, (_: any, observer: Observer<any>) => {        
   let dispose = adapter.streamSubscribe(target, observer)        
   if (proxyStream.__proxyRefs++ === 0) {          
     proxyDispose = adapter.streamSubscribe(
       targetStream, proxyObserver
     )          
   }
   return () => {
     dispose()
     if (--proxyStream.__proxyRefs === 0) {
       proxyDispose()
       proxyObserver.complete()
       if (proxyStream.__onProxyDispose) {
         proxyStream.__onProxyDispose()
       }
     }
   }
 })
开发者ID:whitecolor,项目名称:cycle-circular,代码行数:18,代码来源:index.ts


示例8: events

 public events(eventType: string, options: EventsFnOptions): any {
   const mockConfig = this._mockConfig;
   const keys = Object.keys(mockConfig);
   const keysLen = keys.length;
   for (let i = 0; i < keysLen; i++) {
     const key = keys[i];
     if (key === eventType) {
       return mockConfig[key];
     }
   }
   return this._streamAdapter.adapt(xs.empty(), xsSA.streamSubscribe);
 }
开发者ID:E-LLP,项目名称:dom,代码行数:12,代码来源:mockDOMSource.ts


示例9: define

  define(routes: RouteDefinitions): any {
    const namespace = this._namespace;
    const _createHref = this._createHref;
    const createHref = util.makeCreateHref(namespace, _createHref);

    let match$ = this._runSA.remember(this._history$
      .map((location: Location) => {
        const filteredPath = getFilteredPath(namespace, location.pathname);
        const {path, value} = switchPath(filteredPath, routes);
        return {path, value, location, createHref};
      }));

    match$.createHref = createHref;
    return match$;
  }
开发者ID:lius,项目名称:cyclic-router,代码行数:15,代码来源:RouterSource.ts



注:本文中的@cycle/base.StreamAdapter类示例由纯净天空整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
TypeScript dom.a函数代码示例发布时间:2022-05-28
下一篇:
TypeScript httpclient.HttpClient类代码示例发布时间:2022-05-28
热门推荐
热门话题
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap