fx.html


<!DOCTYPE HTML>
<html lang="zh-hans" >
    <head>
        <meta charset="UTF-8">
        <meta content="text/html; charset=utf-8" http-equiv="Content-Type">
        <title>fx · go-zero使用文档</title>
        <meta http-equiv="X-UA-Compatible" content="IE=edge" />
        <meta name="description" content="">
        <meta name="generator" content="GitBook 3.2.3">
        <meta name="author" content="松妹子">
        
        
    <link rel="stylesheet" href="gitbook/style.css">

    
                <link rel="stylesheet" href="gitbook/gitbook-plugin-back-to-top-button/plugin.css">
                
            
                <link rel="stylesheet" href="gitbook/gitbook-plugin-chapter-fold/chapter-fold.css">
                
            
                <link rel="stylesheet" href="gitbook/gitbook-plugin-code/plugin.css">
                
            
                <link rel="stylesheet" href="gitbook/gitbook-plugin-search-pro/search.css">
                
            
                <link rel="stylesheet" href="gitbook/gitbook-plugin-splitter/splitter.css">
                
            
                <link rel="stylesheet" href="gitbook/gitbook-plugin-tbfed-pagefooter/footer.css">
                
            
                <link rel="stylesheet" href="gitbook/gitbook-plugin-flexible-alerts/style.css">
                
            
                <link rel="stylesheet" href="gitbook/gitbook-plugin-page-toc-button/plugin.css">
                
            
                <link rel="stylesheet" href="gitbook/gitbook-plugin-pageview-count/plugin.css">
                
            
                <link rel="stylesheet" href="gitbook/gitbook-plugin-prism/prism-tomorrow.css">
                
            
                <link rel="stylesheet" href="gitbook/gitbook-plugin-fontsettings/website.css">
                
            
                <link rel="stylesheet" href="gitbook/gitbook-plugin-theme-comscore/test.css">
                
            
    <meta name="HandheldFriendly" content="true"/>
    <meta name="viewport" content="width=device-width, initial-scale=1, user-scalable=no">
    <meta name="apple-mobile-web-app-capable" content="yes">
    <meta name="apple-mobile-web-app-status-bar-style" content="black">
    <link rel="apple-touch-icon-precomposed" sizes="152x152" href="gitbook/images/apple-touch-icon-precomposed-152.png">
    <link rel="shortcut icon" href="gitbook/images/favicon.ico" type="image/x-icon">

    
    <link rel="next" href="mysql.html" />
    
    
    <link rel="prev" href="executors.html" />
    

    </head>
    <body>
        
<div class="book">
    <div class="book-summary">
        
            
<div id="book-search-input" role="search">
    <input type="text" placeholder="输入并搜索" />
</div>

            
                <nav role="navigation">
                

<ul class="summary">
    
    
        <li class="chapter " data-level="1.1" data-path="./">
            
                <a href="./">
            
                    
                    简介
            
                </a>
            

        </li>
    
        <li class="chapter " data-level="1.2" data-path="about-us.html">
            
                <a href="about-us.html">
            
                    
                    关于我们
            
                </a>
            

        </li>
    
        <li class="chapter " data-level="1.3" data-path="join-us.html">
            
                <a href="join-us.html">
            
                    
                    加入我们
            
                </a>
            

        </li>
    
        <li class="chapter " data-level="1.4" data-path="concept-introduction.html">
            
                <a href="concept-introduction.html">
            
                    
                    概念介绍
            
                </a>
            

        </li>
    
        <li class="chapter " data-level="1.5" data-path="quick-start.html">
            
                <a href="quick-start.html">
            
                    
                    快速开发
            
                </a>
            

            <ul class="articles">
                
    
        <li class="chapter " data-level="1.5.1" data-path="monolithic-service.html">
            
                <a href="monolithic-service.html">
            
                    
                    单体服务
            
                </a>
            

        </li>
    
        <li class="chapter " data-level="1.5.2" data-path="micro-service.html">
            
                <a href="micro-service.html">
            
                    
                    微服务
            
                </a>
            

        </li>
    

            </ul>
            
        </li>
    
        <li class="chapter " data-level="1.6" data-path="framework-design.html">
            
                <a href="framework-design.html">
            
                    
                    框架设计
            
                </a>
            

            <ul class="articles">
                
    
        <li class="chapter " data-level="1.6.1" data-path="go-zero-design.html">
            
                <a href="go-zero-design.html">
            
                    
                    go-zero设计理念
            
                </a>
            

        </li>
    
        <li class="chapter " data-level="1.6.2" data-path="go-zero-features.html">
            
                <a href="go-zero-features.html">
            
                    
                    go-zero特点
            
                </a>
            

        </li>
    
        <li class="chapter " data-level="1.6.3" data-path="api-grammar.html">
            
                <a href="api-grammar.html">
            
                    
                    api语法介绍
            
                </a>
            

        </li>
    
        <li class="chapter " data-level="1.6.4" data-path="api-dir.html">
            
                <a href="api-dir.html">
            
                    
                    api目录结构
            
                </a>
            

        </li>
    
        <li class="chapter " data-level="1.6.5" data-path="rpc-dir.html">
            
                <a href="rpc-dir.html">
            
                    
                    rpc目录结构
            
                </a>
            

        </li>
    

            </ul>
            
        </li>
    
        <li class="chapter " data-level="1.7" data-path="project-dev.html">
            
                <a href="project-dev.html">
            
                    
                    项目开发
            
                </a>
            

            <ul class="articles">
                
    
        <li class="chapter " data-level="1.7.1" data-path="prepare.html">
            
                <a href="prepare.html">
            
                    
                    准备工作
            
                </a>
            

            <ul class="articles">
                
    
        <li class="chapter " data-level="1.7.1.1" data-path="golang-install.html">
            
                <a href="golang-install.html">
            
                    
                    golang安装
            
                </a>
            

        </li>
    
        <li class="chapter " data-level="1.7.1.2" data-path="gomod-config.html">
            
                <a href="gomod-config.html">
            
                    
                    go modudle配置
            
                </a>
            

        </li>
    
        <li class="chapter " data-level="1.7.1.3" data-path="goctl-install.html">
            
                <a href="goctl-install.html">
            
                    
                    goctl安装
            
                </a>
            

        </li>
    
        <li class="chapter " data-level="1.7.1.4" data-path="protoc-install.html">
            
                <a href="protoc-install.html">
            
                    
                    protoc&protoc-gen-go安装
            
                </a>
            

        </li>
    
        <li class="chapter " data-level="1.7.1.5" data-path="prepare-other.html">
            
                <a href="prepare-other.html">
            
                    
                    其他
            
                </a>
            

        </li>
    

            </ul>
            
        </li>
    
        <li class="chapter " data-level="1.7.2" data-path="dev-specification.html">
            
                <a href="dev-specification.html">
            
                    
                    开发规范
            
                </a>
            

            <ul class="articles">
                
    
        <li class="chapter " data-level="1.7.2.1" data-path="naming-spec.html">
            
                <a href="naming-spec.html">
            
                    
                    命名规范
            
                </a>
            

        </li>
    
        <li class="chapter " data-level="1.7.2.2" data-path="route-naming-spec.html">
            
                <a href="route-naming-spec.html">
            
                    
                    路由规范
            
                </a>
            

        </li>
    
        <li class="chapter " data-level="1.7.2.3" data-path="coding-spec.html">
            
                <a href="coding-spec.html">
            
                    
                    编码规范
            
                </a>
            

        </li>
    

            </ul>
            
        </li>
    
        <li class="chapter " data-level="1.7.3" data-path="dev-flow.html">
            
                <a href="dev-flow.html">
            
                    
                    开发流程
            
                </a>
            

        </li>
    
        <li class="chapter " data-level="1.7.4" data-path="config-introduction.html">
            
                <a href="config-introduction.html">
            
                    
                    配置介绍
            
                </a>
            

            <ul class="articles">
                
    
        <li class="chapter " data-level="1.7.4.1" data-path="api-config.html">
            
                <a href="api-config.html">
            
                    
                    api配置
            
                </a>
            

        </li>
    
        <li class="chapter " data-level="1.7.4.2" data-path="rpc-config.html">
            
                <a href="rpc-config.html">
            
                    
                    rpc配置
            
                </a>
            

        </li>
    

            </ul>
            
        </li>
    
        <li class="chapter " data-level="1.7.5" data-path="business-dev.html">
            
                <a href="business-dev.html">
            
                    
                    业务开发
            
                </a>
            

            <ul class="articles">
                
    
        <li class="chapter " data-level="1.7.5.1" data-path="service-design.html">
            
                <a href="service-design.html">
            
                    
                    目录拆分
            
                </a>
            

        </li>
    
        <li class="chapter " data-level="1.7.5.2" data-path="model-gen.html">
            
                <a href="model-gen.html">
            
                    
                    model生成
            
                </a>
            

        </li>
    
        <li class="chapter " data-level="1.7.5.3" data-path="api-coding.html">
            
                <a href="api-coding.html">
            
                    
                    api文件编写
            
                </a>
            

        </li>
    
        <li class="chapter " data-level="1.7.5.4" data-path="business-coding.html">
            
                <a href="business-coding.html">
            
                    
                    业务编码
            
                </a>
            

        </li>
    
        <li class="chapter " data-level="1.7.5.5" data-path="jwt.html">
            
                <a href="jwt.html">
            
                    
                    jwt鉴权
            
                </a>
            

        </li>
    
        <li class="chapter " data-level="1.7.5.6" data-path="middleware.html">
            
                <a href="middleware.html">
            
                    
                    中间件使用
            
                </a>
            

        </li>
    
        <li class="chapter " data-level="1.7.5.7" data-path="rpc-call.html">
            
                <a href="rpc-call.html">
            
                    
                    rpc服务编写与调用
            
                </a>
            

        </li>
    
        <li class="chapter " data-level="1.7.5.8" data-path="error-handle.html">
            
                <a href="error-handle.html">
            
                    
                    错误处理
            
                </a>
            

        </li>
    

            </ul>
            
        </li>
    
        <li class="chapter " data-level="1.7.6" data-path="ci-cd.html">
            
                <a href="ci-cd.html">
            
                    
                    CI/CD
            
                </a>
            

        </li>
    
        <li class="chapter " data-level="1.7.7" data-path="service-deployment.html">
            
                <a href="service-deployment.html">
            
                    
                    服务部署
            
                </a>
            

        </li>
    
        <li class="chapter " data-level="1.7.8" data-path="log-collection.html">
            
                <a href="log-collection.html">
            
                    
                    日志收集
            
                </a>
            

        </li>
    
        <li class="chapter " data-level="1.7.9" data-path="trace.html">
            
                <a href="trace.html">
            
                    
                    链路追踪
            
                </a>
            

        </li>
    
        <li class="chapter " data-level="1.7.10" data-path="service-monitor.html">
            
                <a href="service-monitor.html">
            
                    
                    服务监控
            
                </a>
            

        </li>
    

            </ul>
            
        </li>
    
        <li class="chapter " data-level="1.8" data-path="goctl.html">
            
                <a href="goctl.html">
            
                    
                    Goctl
            
                </a>
            

            <ul class="articles">
                
    
        <li class="chapter " data-level="1.8.1" data-path="goctl-commands.html">
            
                <a href="goctl-commands.html">
            
                    
                    命令大全
            
                </a>
            

        </li>
    
        <li class="chapter " data-level="1.8.2" data-path="goctl-api.html">
            
                <a href="goctl-api.html">
            
                    
                    api命令
            
                </a>
            

        </li>
    
        <li class="chapter " data-level="1.8.3" data-path="goctl-rpc.html">
            
                <a href="goctl-rpc.html">
            
                    
                    rpc命令
            
                </a>
            

        </li>
    
        <li class="chapter " data-level="1.8.4" data-path="goctl-model.html">
            
                <a href="goctl-model.html">
            
                    
                    model命令
            
                </a>
            

        </li>
    
        <li class="chapter " data-level="1.8.5" data-path="goctl-plugin.html">
            
                <a href="goctl-plugin.html">
            
                    
                    plugin命令
            
                </a>
            

        </li>
    
        <li class="chapter " data-level="1.8.6" data-path="goctl-other.html">
            
                <a href="goctl-other.html">
            
                    
                    其他命令
            
                </a>
            

        </li>
    

            </ul>
            
        </li>
    
        <li class="chapter " data-level="1.9" data-path="component-center.html">
            
                <a href="component-center.html">
            
                    
                    组件中心
            
                </a>
            

            <ul class="articles">
                
    
        <li class="chapter " data-level="1.9.1" data-path="logx.html">
            
                <a href="logx.html">
            
                    
                    logx
            
                </a>
            

        </li>
    
        <li class="chapter " data-level="1.9.2" data-path="bloom.html">
            
                <a href="bloom.html">
            
                    
                    bloom
            
                </a>
            

        </li>
    
        <li class="chapter " data-level="1.9.3" data-path="executors.html">
            
                <a href="executors.html">
            
                    
                    executors
            
                </a>
            

        </li>
    
        <li class="chapter active" data-level="1.9.4" data-path="fx.html">
            
                <a href="fx.html">
            
                    
                    fx
            
                </a>
            

        </li>
    
        <li class="chapter " data-level="1.9.5" data-path="mysql.html">
            
                <a href="mysql.html">
            
                    
                    mysql
            
                </a>
            

        </li>
    
        <li class="chapter " data-level="1.9.6" data-path="redis-lock.html">
            
                <a href="redis-lock.html">
            
                    
                    redis-lock
            
                </a>
            

        </li>
    
        <li class="chapter " data-level="1.9.7" data-path="periodlimit.html">
            
                <a href="periodlimit.html">
            
                    
                    periodlimit
            
                </a>
            

        </li>
    
        <li class="chapter " data-level="1.9.8" data-path="tokenlimit.html">
            
                <a href="tokenlimit.html">
            
                    
                    tokenlimit
            
                </a>
            

        </li>
    
        <li class="chapter " data-level="1.9.9" data-path="timing-wheel.html">
            
                <a href="timing-wheel.html">
            
                    
                    TimingWheel
            
                </a>
            

        </li>
    

            </ul>
            
        </li>
    
        <li class="chapter " data-level="1.10" data-path="tool-center.html">
            
                <a href="tool-center.html">
            
                    
                    工具中心
            
                </a>
            

            <ul class="articles">
                
    
        <li class="chapter " data-level="1.10.1" data-path="intellij.html">
            
                <a href="intellij.html">
            
                    
                    intellij插件
            
                </a>
            

        </li>
    
        <li class="chapter " data-level="1.10.2" data-path="vscode.html">
            
                <a href="vscode.html">
            
                    
                    vscode插件
            
                </a>
            

        </li>
    

            </ul>
            
        </li>
    
        <li class="chapter " data-level="1.11" data-path="plugin-center.html">
            
                <a href="plugin-center.html">
            
                    
                    插件中心
            
                </a>
            

        </li>
    
        <li class="chapter " data-level="1.12" data-path="learning-resource.html">
            
                <a href="learning-resource.html">
            
                    
                    学习资源
            
                </a>
            

            <ul class="articles">
                
    
        <li class="chapter " data-level="1.12.1" data-path="wechat.html">
            
                <a href="wechat.html">
            
                    
                    公众号
            
                </a>
            

        </li>
    
        <li class="chapter " data-level="1.12.2" data-path="goreading.html">
            
                <a href="goreading.html">
            
                    
                    Go夜读
            
                </a>
            

        </li>
    
        <li class="chapter " data-level="1.12.3" data-path="gotalk.html">
            
                <a href="gotalk.html">
            
                    
                    Go开源说
            
                </a>
            

        </li>
    

            </ul>
            
        </li>
    
        <li class="chapter " data-level="1.13" data-path="practise.html">
            
                <a href="practise.html">
            
                    
                    开发实践
            
                </a>
            

            <ul class="articles">
                
    
        <li class="chapter " data-level="1.13.1" data-path="redis-cache.html">
            
                <a href="redis-cache.html">
            
                    
                    go-zero缓存设计之持久层缓存
            
                </a>
            

        </li>
    
        <li class="chapter " data-level="1.13.2" data-path="buiness-cache.html">
            
                <a href="buiness-cache.html">
            
                    
                    go-zero缓存设计之业务层缓存
            
                </a>
            

        </li>
    
        <li class="chapter " data-level="1.13.3" data-path="go-queue.html">
            
                <a href="go-queue.html">
            
                    
                    go-zero分布式定时任务
            
                </a>
            

        </li>
    
        <li class="chapter " data-level="1.13.4" data-path="datacenter.html">
            
                <a href="datacenter.html">
            
                    
                    我是如何用go-zero 实现一个中台系统
            
                </a>
            

        </li>
    
        <li class="chapter " data-level="1.13.5" data-path="stream.html">
            
                <a href="stream.html">
            
                    
                    流数据处理利器
            
                </a>
            

        </li>
    
        <li class="chapter " data-level="1.13.6" data-path="online-exchange.html">
            
                <a href="online-exchange.html">
            
                    
                    10月3日线上交流问题汇总
            
                </a>
            

        </li>
    

            </ul>
            
        </li>
    
        <li class="chapter " data-level="1.14" data-path="dev-log.html">
            
                <a href="dev-log.html">
            
                    
                    开发日志
            
                </a>
            

            <ul class="articles">
                
    
        <li class="chapter " data-level="1.14.1" data-path="goctl-log.html">
            
                <a href="goctl-log.html">
            
                    
                    goctl开发日志
            
                </a>
            

        </li>
    
        <li class="chapter " data-level="1.14.2" data-path="intellij-log.html">
            
                <a href="intellij-log.html">
            
                    
                    intellij开发日志
            
                </a>
            

        </li>
    

            </ul>
            
        </li>
    
        <li class="chapter " data-level="1.15" data-path="contributor.html">
            
                <a href="contributor.html">
            
                    
                    贡献人员
            
                </a>
            

        </li>
    
        <li class="chapter " data-level="1.16" data-path="doc-contibute.html">
            
                <a href="doc-contibute.html">
            
                    
                    文档贡献
            
                </a>
            

        </li>
    
        <li class="chapter " data-level="1.17" data-path="error.html">
            
                <a href="error.html">
            
                    
                    常见错误处理
            
                </a>
            

        </li>
    
        <li class="chapter " data-level="1.18" data-path="source.html">
            
                <a href="source.html">
            
                    
                    相关源码
            
                </a>
            

        </li>
    

    <li class="divider"></li>

    <li>
        <a href="https://www.gitbook.com" target="blank" class="gitbook-link">
            本书使用 GitBook 发布
        </a>
    </li>
</ul>


                </nav>
            
        
    </div>

    <div class="book-body">
        
            <div class="body-inner">
                
                    
<div class="book-header" role="navigation">
    

    <!-- Title -->
    <h1>
        <i class="fa fa-circle-o-notch fa-spin"></i>
        <a href="." >fx</a>
    </h1>
</div>


                    <div class="page-wrapper" tabindex="-1" role="main">
                        <div class="page-inner">
                            
<div id="book-search-results">
    <div class="search-noresults">
    
                                <section class="normal markdown-section">
                                
                                <h1 id="fx">fx</h1>
<p><code>fx</code> &#x662F;&#x4E00;&#x4E2A;&#x5B8C;&#x5907;&#x7684;&#x6D41;&#x5F0F;&#x5904;&#x7406;&#x7EC4;&#x4EF6;&#x3002;
&#x548C; <code>MapReduce</code> &#x7C7B;&#x4F3C;&#x7684;&#xFF0C;<code>fx</code> &#x4E5F;&#x5B58;&#x5728;&#x5E76;&#x53D1;&#x5904;&#x7406;&#x7684;&#x51FD;&#x6570;&#xFF1A;<code>Parallel(fn, options)</code>&#x3002;&#x4F46;&#x540C;&#x65F6;&#x5B83;&#x4E5F;&#x4E0D;&#x53EA;&#x6709;&#x5E76;&#x53D1;&#x5904;&#x7406;&#x3002;<code>From(chan)</code> &#xFF0C;<code>Map(fn)</code>&#xFF0C;<code>Filter(fn)</code>&#xFF0C;<code>Reduce(fn)</code>  &#x7B49;&#xFF0C;&#x4ECE;&#x6570;&#x636E;&#x6E90;&#x8BFB;&#x53D6;&#x6210;&#x6D41;&#xFF0C;&#x5230;&#x5904;&#x7406;&#x6D41;&#x6570;&#x636E;&#xFF0C;&#x6700;&#x540E;&#x805A;&#x5408;&#x6D41;&#x6570;&#x636E;&#x3002;&#x662F;&#x4E0D;&#x662F;&#x6709;&#x70B9;&#x50CF; <code>Java Lambda</code> &#xFF0C;&#x5982;&#x679C;&#x4F60;&#x4E4B;&#x524D;&#x662F; <code>Java</code> &#x5F00;&#x53D1;&#x8005;&#xFF0C;&#x770B;&#x5230;&#x8FD9;&#x4E5F;&#x5C31;&#x660E;&#x767D;&#x6574;&#x4E2A;&#x57FA;&#x672C;&#x8BBE;&#x8BA1;&#x3002;</p>
<h2 id="&#x6574;&#x4F53;api">&#x6574;&#x4F53;API</h2>
<p>&#x8FD8;&#x662F;&#x4ECE;&#x6574;&#x4F53;&#x4E0A;&#x6982;&#x89C8; <code>fx</code> &#x5230;&#x5E95;&#x662F;&#x600E;&#x4E48;&#x6784;&#x5EFA;&#x7684;&#xFF1A;
<img src="resource/dc500acd526d40aabfe4f53cf5bd180a_tplv-k3u1fbpfcp-zoom-1.png" alt="dc500acd526d40aabfe4f53cf5bd180a_tplv-k3u1fbpfcp-zoom-1.png"></p>
<p>&#x88AB;&#x6807;&#x6CE8;&#x7684;&#x90E8;&#x5206;&#x5C31;&#x662F;&#x6574;&#x4E2A; <code>fx</code> &#x6700;&#x91CD;&#x8981;&#x7684;&#x90E8;&#x5206;&#xFF1A;</p>
<ol>
<li>&#x7531; <code>From(fn)</code> &#x8FD9;&#x7C7B;API&#xFF0C;&#x4EA7;&#x751F;&#x6570;&#x636E;&#x6D41; <code>Stream</code></li>
<li>&#x5BF9;<code>Stream</code>  &#x8F6C;&#x6362;&#xFF0C;&#x805A;&#x5408;&#xFF0C;&#x6C42;&#x503C;&#x7684;API&#x96C6;&#x5408;</li>
</ol>
<p>&#x6240;&#x4EE5;&#x5217;&#x4E3E;&#x51FA;&#x76EE;&#x524D;&#x652F;&#x6301;&#x7684; <code>Stream API</code>&#xFF1A;</p>
<table>
<thead>
<tr>
<th>API</th>
<th>&#x4F5C;&#x7528;</th>
</tr>
</thead>
<tbody>
<tr>
<td><code>Distinct(fn)</code></td>
<td>fn&#x4E2D;&#x9009;&#x5B9A;&#x7279;&#x5B9A;item&#x7C7B;&#x578B;&#xFF0C;&#x5BF9;&#x5176;&#x53BB;&#x91CD;</td>
</tr>
<tr>
<td><code>Filter(fn, option)</code></td>
<td>fn&#x6307;&#x5B9A;&#x5177;&#x4F53;&#x89C4;&#x5219;&#xFF0C;&#x6EE1;&#x8DB3;&#x89C4;&#x5219;&#x7684;<code>element</code>&#x4F20;&#x9012;&#x7ED9;&#x4E0B;&#x4E00;&#x4E2A; <code>stream</code></td>
</tr>
<tr>
<td><code>Group(fn)</code></td>
<td>&#x6839;&#x636E;fn&#x628A;<code>stream</code>&#x4E2D;&#x7684;element&#x5206;&#x5230;&#x4E0D;&#x540C;&#x7684;&#x7EC4;&#x4E2D;</td>
</tr>
<tr>
<td><code>Head(num)</code></td>
<td>&#x53D6;&#x51FA;<code>stream</code>&#x4E2D;&#x524D; num &#x4E2A;element &#xFF0C;&#x751F;&#x6210;&#x4E00;&#x4E2A;&#x65B0;&#x7684;<code>stream</code></td>
</tr>
<tr>
<td><code>Map(fn, option)</code></td>
<td>&#x5C06;&#x6BCF;&#x4E2A;ele&#x8F6C;&#x6362;&#x4E3A;&#x53E6;&#x4E00;&#x4E2A;&#x5BF9;&#x5E94;&#x7684;ele&#xFF0C; &#x4F20;&#x9012;&#x7ED9;&#x4E0B;&#x4E00;&#x4E2A; <code>stream</code></td>
</tr>
<tr>
<td><code>Merge()</code></td>
<td>&#x5C06;&#x6240;&#x6709;<code>ele</code>&#x5408;&#x5E76;&#x5230;&#x4E00;&#x4E2A;<code>slice</code>&#x4E2D;&#x5E76;&#x751F;&#x6210;&#x4E00;&#x4E2A;&#x65B0;<code>stream</code></td>
</tr>
<tr>
<td><code>Reverse()</code></td>
<td>&#x53CD;&#x8F6C;<code>stream</code>&#x4E2D;&#x7684;element&#x3002;&#x3010;&#x4F7F;&#x7528;&#x53CC;&#x6307;&#x9488;&#x3011;</td>
</tr>
<tr>
<td><code>Sort(fn)</code></td>
<td>&#x6309;&#x7167; fn &#x6392;&#x5E8F;<code>stream</code>&#x4E2D;&#x7684;element</td>
</tr>
<tr>
<td><code>Tail(num)</code></td>
<td>&#x53D6;&#x51FA;<code>stream</code>&#x6700;&#x540E;&#x7684; num &#x4E2A;element&#xFF0C;&#x751F;&#x6210;&#x4E00;&#x4E2A;&#x65B0; <code>stream</code>&#x3002;&#x3010;&#x4F7F;&#x7528;&#x53CC;&#x5411;&#x73AF;&#x72B6;&#x94FE;&#x8868;&#x3011;</td>
</tr>
<tr>
<td><code>Walk(fn, option)</code></td>
<td>&#x628A; fn &#x4F5C;&#x7528;&#x5728; <code>source</code> &#x7684;&#x6BCF;&#x4E2A;&#x5143;&#x7D20;&#x3002;&#x751F;&#x6210;&#x65B0;&#x7684; <code>stream</code></td>
</tr>
</tbody>
</table>
<p>&#x4E0D;&#x518D;&#x751F;&#x6210;&#x65B0;&#x7684; <code>stream</code>&#xFF0C;&#x505A;&#x6700;&#x540E;&#x7684;&#x6C42;&#x503C;&#x64CD;&#x4F5C;&#xFF1A;</p>
<table>
<thead>
<tr>
<th>API</th>
<th>&#x4F5C;&#x7528;</th>
</tr>
</thead>
<tbody>
<tr>
<td><code>ForAll(fn)</code></td>
<td>&#x6309;&#x7167;fn&#x5904;&#x7406;<code>stream</code>&#xFF0C;&#x4E14;&#x4E0D;&#x518D;&#x4EA7;&#x751F;<code>stream</code>&#x3010;&#x6C42;&#x503C;&#x64CD;&#x4F5C;&#x3011;</td>
</tr>
<tr>
<td><code>ForEach(fn)</code></td>
<td>&#x5BF9; <code>stream</code>  &#x4E2D;&#x6240;&#x6709; element &#x6267;&#x884C;fn&#x3010;&#x6C42;&#x503C;&#x64CD;&#x4F5C;&#x3011;</td>
</tr>
<tr>
<td><code>Parallel(fn, option)</code></td>
<td>&#x5C06;&#x7ED9;&#x5B9A;&#x7684;fn&#x4E0E;&#x7ED9;&#x5B9A;&#x7684;worker&#x6570;&#x91CF;&#x5E76;&#x53D1;&#x5E94;&#x7528;&#x4E8E;&#x6BCF;&#x4E2A;<code>element</code>&#x3010;&#x6C42;&#x503C;&#x64CD;&#x4F5C;&#x3011;</td>
</tr>
<tr>
<td><code>Reduce(fn)</code></td>
<td>&#x76F4;&#x63A5;&#x5904;&#x7406;<code>stream</code>&#x3010;&#x6C42;&#x503C;&#x64CD;&#x4F5C;&#x3011;</td>
</tr>
<tr>
<td><code>Done()</code></td>
<td>&#x5565;&#x4E5F;&#x4E0D;&#x505A;&#xFF0C;&#x7B49;&#x5F85;&#x6240;&#x6709;&#x7684;&#x64CD;&#x4F5C;&#x5B8C;&#x6210;</td>
</tr>
</tbody>
</table>
<h2 id="&#x5982;&#x4F55;&#x4F7F;&#x7528;">&#x5982;&#x4F55;&#x4F7F;&#x7528;</h2>
<pre class="language-"><code class="lang-go">result <span class="token operator">:=</span> <span class="token function">make</span><span class="token punctuation">(</span><span class="token keyword">map</span><span class="token punctuation">[</span><span class="token builtin">string</span><span class="token punctuation">]</span><span class="token builtin">string</span><span class="token punctuation">)</span>
fx<span class="token punctuation">.</span><span class="token function">From</span><span class="token punctuation">(</span><span class="token keyword">func</span><span class="token punctuation">(</span>source <span class="token keyword">chan</span><span class="token operator">&lt;-</span> <span class="token keyword">interface</span><span class="token punctuation">{</span><span class="token punctuation">}</span><span class="token punctuation">)</span> <span class="token punctuation">{</span>
  <span class="token keyword">for</span> <span class="token boolean">_</span><span class="token punctuation">,</span> item <span class="token operator">:=</span> <span class="token keyword">range</span> data <span class="token punctuation">{</span>
    source <span class="token operator">&lt;-</span> item
  <span class="token punctuation">}</span>
<span class="token punctuation">}</span><span class="token punctuation">)</span><span class="token punctuation">.</span><span class="token function">Walk</span><span class="token punctuation">(</span><span class="token keyword">func</span><span class="token punctuation">(</span>item <span class="token keyword">interface</span><span class="token punctuation">{</span><span class="token punctuation">}</span><span class="token punctuation">,</span> pipe <span class="token keyword">chan</span><span class="token operator">&lt;-</span> <span class="token keyword">interface</span><span class="token punctuation">{</span><span class="token punctuation">}</span><span class="token punctuation">)</span> <span class="token punctuation">{</span>
  each <span class="token operator">:=</span> item<span class="token punctuation">.</span><span class="token punctuation">(</span><span class="token operator">*</span>model<span class="token punctuation">.</span>ClassData<span class="token punctuation">)</span>

  class<span class="token punctuation">,</span> err <span class="token operator">:=</span> l<span class="token punctuation">.</span>rpcLogic<span class="token punctuation">.</span><span class="token function">GetClassInfo</span><span class="token punctuation">(</span><span class="token punctuation">)</span>
  <span class="token keyword">if</span> err <span class="token operator">!=</span> <span class="token boolean">nil</span> <span class="token punctuation">{</span>
    l<span class="token punctuation">.</span><span class="token function">Errorf</span><span class="token punctuation">(</span><span class="token string">&quot;get class %s failed: %s&quot;</span><span class="token punctuation">,</span> each<span class="token punctuation">.</span>ClassId<span class="token punctuation">,</span> err<span class="token punctuation">.</span><span class="token function">Error</span><span class="token punctuation">(</span><span class="token punctuation">)</span><span class="token punctuation">)</span>
    <span class="token keyword">return</span>
  <span class="token punctuation">}</span>

  students<span class="token punctuation">,</span> err <span class="token operator">:=</span> l<span class="token punctuation">.</span>rpcLogic<span class="token punctuation">.</span><span class="token function">GetUsersInfo</span><span class="token punctuation">(</span>class<span class="token punctuation">.</span>ClassId<span class="token punctuation">)</span>
  <span class="token keyword">if</span> err <span class="token operator">!=</span> <span class="token boolean">nil</span> <span class="token punctuation">{</span>
    l<span class="token punctuation">.</span><span class="token function">Errorf</span><span class="token punctuation">(</span><span class="token string">&quot;get students %s failed: %s&quot;</span><span class="token punctuation">,</span> each<span class="token punctuation">.</span>ClassId<span class="token punctuation">,</span> err<span class="token punctuation">.</span><span class="token function">Error</span><span class="token punctuation">(</span><span class="token punctuation">)</span><span class="token punctuation">)</span>
    <span class="token keyword">return</span>
  <span class="token punctuation">}</span>

  pipe <span class="token operator">&lt;-</span> <span class="token operator">&amp;</span>classObj<span class="token punctuation">{</span>
    classId<span class="token punctuation">:</span> each<span class="token punctuation">.</span>ClassId
    studentIds<span class="token punctuation">:</span> students
  <span class="token punctuation">}</span>
<span class="token punctuation">}</span><span class="token punctuation">)</span><span class="token punctuation">.</span><span class="token function">ForEach</span><span class="token punctuation">(</span><span class="token keyword">func</span><span class="token punctuation">(</span>item <span class="token keyword">interface</span><span class="token punctuation">{</span><span class="token punctuation">}</span><span class="token punctuation">)</span> <span class="token punctuation">{</span>
    o <span class="token operator">:=</span> item<span class="token punctuation">.</span><span class="token punctuation">(</span><span class="token operator">*</span>classObj<span class="token punctuation">)</span>
    result<span class="token punctuation">[</span>o<span class="token punctuation">.</span>classId<span class="token punctuation">]</span> <span class="token operator">=</span> o<span class="token punctuation">.</span>studentIds
<span class="token punctuation">}</span><span class="token punctuation">)</span>
</code></pre>
<ol>
<li><code>From()</code> &#x4ECE;&#x4E00;&#x4E2A; <code>slice</code> &#x751F;&#x6210; <code>stream</code></li>
<li><code>Walk()</code> &#x63A5;&#x6536;&#x4E0E;&#x4E00;&#x4E2A; <code>stream</code> &#xFF0C;&#x5BF9;&#x6D41;&#x4E2D;&#x6BCF;&#x4E2A; <code>ele</code> &#x8F6C;&#x6362;&#x91CD;&#x7EC4;&#xFF0C;&#x751F;&#x6210;&#x65B0;&#x7684; <code>stream</code></li>
<li>&#x6700;&#x540E;&#x7531; <code>&#x6C42;&#x503C;&#x64CD;&#x4F5C;</code> &#x628A; <code>stream</code> &#x8F93;&#x51FA;&#xFF08;<code>fmt.Println</code>&#xFF09;&#xFF0C;&#x5B58;&#x50A8;&#xFF08;<code>map,slice</code>&#xFF09;&#xFF0C;&#x6301;&#x4E45;&#x5316;&#xFF08;<code>db&#x64CD;&#x4F5C;</code>&#xFF09;</li>
</ol>
<h2 id="&#x7B80;&#x8981;&#x5206;&#x6790;">&#x7B80;&#x8981;&#x5206;&#x6790;</h2>
<p><code>fx</code> &#x4E2D;&#x7684;&#x51FD;&#x6570;&#x547D;&#x540D;&#x8BED;&#x4E49;&#x5316;&#xFF0C;&#x5F00;&#x53D1;&#x8005;&#x53EA;&#x9700;&#x8981;&#x77E5;&#x9053;&#x4E1A;&#x52A1;&#x903B;&#x8F91;&#x9700;&#x8981;&#x4EC0;&#x4E48;&#x6837;&#x7684;&#x8F6C;&#x6362;&#xFF0C;&#x8C03;&#x7528;&#x4E0E;&#x4E4B;&#x5339;&#x914D;&#x7684;&#x51FD;&#x6570;&#x5373;&#x53EF;&#x3002;</p>
<p>&#x6240;&#x4EE5;&#x8FD9;&#x91CC;&#x53EA;&#x7B80;&#x8981;&#x5206;&#x6790;&#x51E0;&#x4E2A;&#x6BD4;&#x8F83;&#x5178;&#x578B;&#x7684;&#x51FD;&#x6570;&#x3002;</p>
<h3 id="walk">Walk()</h3>
<p><code>Walk()</code> &#x5728;&#x6574;&#x4E2A; <code>fx</code> &#x88AB;&#x591A;&#x4E2A;&#x51FD;&#x6570;&#x5F53;&#x6210;&#x5E95;&#x5C42;&#x5B9E;&#x73B0;&#xFF0C;<code>Map(), Filter()</code> &#x7B49;&#x3002;</p>
<p>&#x6240;&#x4EE5;&#x672C;&#x8D28;&#x5C31;&#x662F;&#xFF1A;<code>Walk()</code> &#x8D1F;&#x8D23;&#x5E76;&#x53D1;&#x5C06;&#x4F20;&#x8FDB;&#x6765;&#x7684;&#x51FD;&#x6570;&#x4F5C;&#x7528;&#x5728; <strong>&#x8F93;&#x5165;&#x6D41;</strong> &#x7684;&#x6BCF;&#x4E2A; <code>ele</code>&#xFF0C;&#x5E76; &#x751F;&#x6210;&#x65B0;&#x7684; <code>stream</code>&#x3002;</p>
<p>&#x8DDF;&#x5230;&#x6E90;&#x7801;&#xFF0C;&#x5206;&#x6210;&#x4E24;&#x4E2A;&#x5B50;&#x51FD;&#x6570;&#xFF1A;&#x81EA;&#x5B9A;&#x4E49; <code>worker</code> &#x6570;&#xFF0C;&#x9ED8;&#x8BA4; <code>worker</code> &#x6570;</p>
<pre class="language-"><code class="lang-go"><span class="token comment">// &#x81EA;&#x5B9A;&#x4E49; workder &#x6570;</span>
<span class="token keyword">func</span> <span class="token punctuation">(</span>p Stream<span class="token punctuation">)</span> <span class="token function">walkLimited</span><span class="token punctuation">(</span>fn WalkFunc<span class="token punctuation">,</span> option <span class="token operator">*</span>rxOptions<span class="token punctuation">)</span> Stream <span class="token punctuation">{</span>
    pipe <span class="token operator">:=</span> <span class="token function">make</span><span class="token punctuation">(</span><span class="token keyword">chan</span> <span class="token keyword">interface</span><span class="token punctuation">{</span><span class="token punctuation">}</span><span class="token punctuation">,</span> option<span class="token punctuation">.</span>workers<span class="token punctuation">)</span>

    <span class="token keyword">go</span> <span class="token keyword">func</span><span class="token punctuation">(</span><span class="token punctuation">)</span> <span class="token punctuation">{</span>
        <span class="token keyword">var</span> wg sync<span class="token punctuation">.</span>WaitGroup
    <span class="token comment">// channel&lt;- &#x5982;&#x679C;&#x8FBE;&#x5230;&#x8BBE;&#x5B9A;workers&#x6570;&#xFF0C;channel&#x963B;&#x585E;&#xFF0C;&#x4ECE;&#x800C;&#x8FBE;&#x5230;&#x63A7;&#x5236;&#x5E76;&#x53D1;&#x6570;&#x3002;</span>
    <span class="token comment">// &#x7B80;&#x6613;&#x7684; goroutine pool</span>
        pool <span class="token operator">:=</span> <span class="token function">make</span><span class="token punctuation">(</span><span class="token keyword">chan</span> lang<span class="token punctuation">.</span>PlaceholderType<span class="token punctuation">,</span> option<span class="token punctuation">.</span>workers<span class="token punctuation">)</span>

        <span class="token keyword">for</span> <span class="token punctuation">{</span>
      <span class="token comment">// &#x6BCF;&#x4E00;&#x6B21;for&#x5FAA;&#x73AF;&#x90FD;&#x4F1A;&#x5F00;&#x542F;&#x4E00;&#x4E2A;goroutine&#x3002;&#x5982;&#x679C;&#x8FBE;&#x5230;workers&#x6570;&#xFF0C;&#x4ECE;&#x800C;&#x963B;&#x585E;</span>
            pool <span class="token operator">&lt;-</span> lang<span class="token punctuation">.</span>Placeholder
            item<span class="token punctuation">,</span> ok <span class="token operator">:=</span> <span class="token operator">&lt;-</span>p<span class="token punctuation">.</span>source
            <span class="token keyword">if</span> <span class="token operator">!</span>ok <span class="token punctuation">{</span>
                <span class="token operator">&lt;-</span>pool
                <span class="token keyword">break</span>
            <span class="token punctuation">}</span>
            <span class="token comment">// &#x4F7F;&#x7528; waitgroup &#x4FDD;&#x8BC1;&#x4EFB;&#x52A1;&#x5B8C;&#x6210;&#x7684;&#x5B8C;&#x6574;&#x6027;</span>
            wg<span class="token punctuation">.</span><span class="token function">Add</span><span class="token punctuation">(</span><span class="token number">1</span><span class="token punctuation">)</span>
            threading<span class="token punctuation">.</span><span class="token function">GoSafe</span><span class="token punctuation">(</span><span class="token keyword">func</span><span class="token punctuation">(</span><span class="token punctuation">)</span> <span class="token punctuation">{</span>
                <span class="token keyword">defer</span> <span class="token keyword">func</span><span class="token punctuation">(</span><span class="token punctuation">)</span> <span class="token punctuation">{</span>
                    wg<span class="token punctuation">.</span><span class="token function">Done</span><span class="token punctuation">(</span><span class="token punctuation">)</span>
          <span class="token comment">// &#x5F52;&#x8FD8;</span>
                    <span class="token operator">&lt;-</span>pool
                <span class="token punctuation">}</span><span class="token punctuation">(</span><span class="token punctuation">)</span>

                <span class="token function">fn</span><span class="token punctuation">(</span>item<span class="token punctuation">,</span> pipe<span class="token punctuation">)</span>
            <span class="token punctuation">}</span><span class="token punctuation">)</span>
        <span class="token punctuation">}</span>

        wg<span class="token punctuation">.</span><span class="token function">Wait</span><span class="token punctuation">(</span><span class="token punctuation">)</span>
        <span class="token function">close</span><span class="token punctuation">(</span>pipe<span class="token punctuation">)</span>
    <span class="token punctuation">}</span><span class="token punctuation">(</span><span class="token punctuation">)</span>

    <span class="token keyword">return</span> <span class="token function">Range</span><span class="token punctuation">(</span>pipe<span class="token punctuation">)</span>
<span class="token punctuation">}</span>
</code></pre>
<ul>
<li>&#x4F7F;&#x7528; <code>&#x6709;&#x7F13;&#x51B2;channel</code> &#x505A;&#x5E76;&#x53D1;&#x961F;&#x5217;&#xFF0C;&#x9650;&#x5236;&#x5E76;&#x53D1;&#x6570;</li>
<li><code>waitgroup</code> &#x4FDD;&#x8BC1;&#x4EFB;&#x52A1;&#x5B8C;&#x6210;&#x7684;&#x5B8C;&#x6574;&#x6027;</li>
</ul>
<p>&#x53E6;&#x5916;&#x4E00;&#x4E2A; <code>walkUnlimited()</code>&#xFF1A;&#x4E5F;&#x4F7F;&#x7528;&#x4E86; <code>waitgroup</code> &#x505A;&#x5E76;&#x53D1;&#x63A7;&#x5236;&#xFF0C;&#x56E0;&#x4E3A;&#x6CA1;&#x6709;&#x81EA;&#x5B9A;&#x4E49;&#x5E76;&#x53D1;&#x6570;&#x9650;&#x5236;&#xFF0C;&#x6240;&#x4EE5;&#x4E5F;&#x5C31;&#x6CA1;&#x6709;&#x53E6;&#x5916;&#x4E00;&#x4E2A; <code>channel</code> &#x505A;&#x5E76;&#x53D1;&#x6570;&#x63A7;&#x5236;&#x3002;</p>
<h3 id="tail">Tail()</h3>
<p>&#x4ECB;&#x7ECD;&#x8FD9;&#x4E2A;&#x4E3B;&#x8981;&#x662F;&#x91CC;&#x9762;&#x8FD0;&#x7528;&#x4E86; <code>ring</code> &#x8FD9;&#x4E2A;&#x53CC;&#x5411;&#x94FE;&#x8868;&#xFF0C;&#x5176;&#x4E2D;&#x7684;&#x7B80;&#x5355;&#x7B97;&#x6CD5;&#x8FD8;&#x662F;&#x5F88;&#x6709;&#x610F;&#x601D;&#x7684;&#x3002;</p>
<pre class="language-"><code class="lang-go"><span class="token keyword">func</span> <span class="token punctuation">(</span>p Stream<span class="token punctuation">)</span> <span class="token function">Tail</span><span class="token punctuation">(</span>n <span class="token builtin">int64</span><span class="token punctuation">)</span> Stream <span class="token punctuation">{</span>
    source <span class="token operator">:=</span> <span class="token function">make</span><span class="token punctuation">(</span><span class="token keyword">chan</span> <span class="token keyword">interface</span><span class="token punctuation">{</span><span class="token punctuation">}</span><span class="token punctuation">)</span>

    <span class="token keyword">go</span> <span class="token keyword">func</span><span class="token punctuation">(</span><span class="token punctuation">)</span> <span class="token punctuation">{</span>
        ring <span class="token operator">:=</span> collection<span class="token punctuation">.</span><span class="token function">NewRing</span><span class="token punctuation">(</span><span class="token function">int</span><span class="token punctuation">(</span>n<span class="token punctuation">)</span><span class="token punctuation">)</span>
    <span class="token comment">// &#x201C;&#x987A;&#x5E8F;&#x201D;&#x63D2;&#x5165;&#xFF0C;&#x6E90;&#x7684;&#x987A;&#x5E8F;&#x548C;ring&#x7684;&#x987A;&#x5E8F;&#x4E00;&#x81F4;</span>
        <span class="token keyword">for</span> item <span class="token operator">:=</span> <span class="token keyword">range</span> p<span class="token punctuation">.</span>source <span class="token punctuation">{</span>
            ring<span class="token punctuation">.</span><span class="token function">Add</span><span class="token punctuation">(</span>item<span class="token punctuation">)</span>
        <span class="token punctuation">}</span>
    <span class="token comment">// &#x53D6;&#x51FA; ring &#x4E2D;&#x5168;&#x90E8;&#x7684; item</span>
        <span class="token keyword">for</span> <span class="token boolean">_</span><span class="token punctuation">,</span> item <span class="token operator">:=</span> <span class="token keyword">range</span> ring<span class="token punctuation">.</span><span class="token function">Take</span><span class="token punctuation">(</span><span class="token punctuation">)</span> <span class="token punctuation">{</span>
            source <span class="token operator">&lt;-</span> item
        <span class="token punctuation">}</span>
        <span class="token function">close</span><span class="token punctuation">(</span>source<span class="token punctuation">)</span>
    <span class="token punctuation">}</span><span class="token punctuation">(</span><span class="token punctuation">)</span>

    <span class="token keyword">return</span> <span class="token function">Range</span><span class="token punctuation">(</span>source<span class="token punctuation">)</span>
<span class="token punctuation">}</span>
</code></pre>
<p>&#x81F3;&#x4E8E;&#x4E3A;&#x4EC0;&#x4E48; <code>Tail()</code> &#x53EF;&#x4EE5;&#x505A;&#x5230;&#x628A;&#x6E90;&#x7684;&#x540E;n&#x4E2A;&#x53D6;&#x51FA;&#x6765;&#xFF0C;&#x8FD9;&#x4E2A;&#x5C31;&#x7559;&#x7ED9;&#x5927;&#x5BB6;&#x53BB;&#x7EC6;&#x54C1;&#x4E86;&#x3002;&#x8FD9;&#x91CC;&#x7ED9;&#x51FA;&#x6211;&#x7684;&#x7406;&#x89E3;&#xFF1A;
<img src="resource/f93c621571074e44a2d403aa25e7db6f_tplv-k3u1fbpfcp-zoom-1.png" alt="f93c621571074e44a2d403aa25e7db6f_tplv-k3u1fbpfcp-zoom-1.png"></p>
<blockquote>
<p>[!TIP]
&#x5047;&#x8BBE;&#x6709;&#x4EE5;&#x4E0B;&#x8FD9;&#x4E2A;&#x573A;&#x666F;&#xFF0C;<code>Tail(5)</code></p>
<ul>
<li><code>stream size</code> &#xFF1A;7</li>
<li><code>ring size</code>&#xFF1A;5</li>
</ul>
</blockquote>
<p>&#x8FD9;&#x91CC;&#x53EF;&#x4EE5;&#x4F7F;&#x7528;&#x628A;&#x73AF;&#x72B6;&#x94FE;&#x8868;&#x62C9;&#x5F00;&#x7684;&#x65B9;&#x5F0F;&#xFF0C;<strong>&#x73AF;&#x8F6C;&#x7EBF;</strong>&#xFF0C;&#x6B64;&#x65F6;&#x4EE5;&#x5168;&#x90E8;&#x957F;&#x5EA6;&#x5212;&#x5206;&#x5BF9;&#x79F0;&#x8F74;&#xFF0C;&#x7FFB;&#x8F6C;&#x591A;&#x4F59;&#x7684;&#x5143;&#x7D20;&#xFF0C;&#x4E4B;&#x540E;&#x7684;&#x5143;&#x7D20;&#x5C31;&#x662F; <code>Tail(5)</code> &#x9700;&#x8981;&#x7684;&#x90E8;&#x5206;&#x4E86;&#x3002;</p>
<blockquote>
<p>[!TIP]
&#x8FD9;&#x91CC;&#x91C7;&#x7528;&#x56FE;&#x7684;&#x65B9;&#x5F0F;&#x66F4;&#x6E05;&#x6670;&#x7684;&#x8868;&#x73B0;&#xFF0C;&#x4E0D;&#x8FC7;&#x4EE3;&#x7801;&#x5927;&#x5BB6;&#x4E5F;&#x8981;&#x770B;&#x770B;&#x3002;&#x7B97;&#x6CD5;&#x8981;&#x8003;&#x7684; <img src="https://gw.alipayobjects.com/os/lib/twemoji/11.2.0/2/svg/1f528.svg#align=left&amp;display=inline&amp;height=18&amp;margin=%5Bobject%20Object%5D&amp;originHeight=150&amp;originWidth=150&amp;status=done&amp;style=none&amp;width=18" alt=""></p>
</blockquote>
<h3 id="stream-transform-design">Stream Transform Design</h3>
<p>&#x5206;&#x6790;&#x6574;&#x4E2A; <code>fx</code> &#xFF0C;&#x4F1A;&#x53D1;&#x73B0;&#x6574;&#x4F53;&#x8BBE;&#x8BA1;&#x9075;&#x5FAA;&#x4E00;&#x4E2A;&#x8BBE;&#x8BA1;&#x6A21;&#x7248;&#xFF1A;</p>
<pre class="language-"><code class="lang-go"><span class="token keyword">func</span> <span class="token punctuation">(</span>p Stream<span class="token punctuation">)</span> <span class="token function">Transform</span><span class="token punctuation">(</span>fn <span class="token keyword">func</span><span class="token punctuation">(</span>item <span class="token keyword">interface</span><span class="token punctuation">{</span><span class="token punctuation">}</span><span class="token punctuation">)</span> <span class="token keyword">interface</span><span class="token punctuation">{</span><span class="token punctuation">}</span><span class="token punctuation">)</span> Stream <span class="token punctuation">{</span>
    <span class="token comment">// make channel</span>
    source <span class="token operator">:=</span> <span class="token function">make</span><span class="token punctuation">(</span><span class="token keyword">chan</span> <span class="token keyword">interface</span><span class="token punctuation">{</span><span class="token punctuation">}</span><span class="token punctuation">)</span>
    <span class="token comment">// goroutine worker</span>
    <span class="token keyword">go</span> <span class="token keyword">func</span><span class="token punctuation">(</span><span class="token punctuation">)</span> <span class="token punctuation">{</span>
        <span class="token comment">// tranform</span>
        <span class="token keyword">for</span> item <span class="token operator">:=</span> <span class="token keyword">range</span> p<span class="token punctuation">.</span>source <span class="token punctuation">{</span>
            <span class="token operator">...</span>
            source <span class="token operator">&lt;-</span> item
            <span class="token operator">...</span>
        <span class="token punctuation">}</span>
        <span class="token operator">...</span>
        <span class="token comment">// &#x5173;&#x95ED;&#x8F93;&#x5165;&#xFF0C;&#x4F46;&#x662F;&#x4F9D;&#x7136;&#x53EF;&#x4EE5;&#x4ECE;&#x8FD9;&#x4E2A; stream &#x8F93;&#x51FA;&#x3002;&#x9632;&#x6B62;&#x5185;&#x5B58;&#x6CC4;&#x6F0F;</span>
        <span class="token function">close</span><span class="token punctuation">(</span>source<span class="token punctuation">)</span>
    <span class="token punctuation">}</span><span class="token punctuation">(</span><span class="token punctuation">)</span>
    <span class="token comment">// channel -&gt; stream</span>
    <span class="token keyword">return</span> <span class="token function">Range</span><span class="token punctuation">(</span>source<span class="token punctuation">)</span>
<span class="token punctuation">}</span>
</code></pre>
<ul>
<li><code>channel</code> &#x4F5C;&#x4E3A;&#x6D41;&#x7684;&#x5BB9;&#x5668;</li>
<li>&#x5F00; <code>goroutine</code> &#x5BF9; <code>source</code> &#x505A;&#x8F6C;&#x6362;&#xFF0C;&#x805A;&#x5408;&#xFF0C;&#x8F93;&#x9001;&#x5230; <code>channel</code></li>
<li>&#x5904;&#x7406;&#x5B8C;&#x6BD5;&#xFF0C;<code>close(outputStream)</code></li>
<li><code>channel -&gt; stream</code></li>
</ul>
<h2 id="&#x603B;&#x7ED3;">&#x603B;&#x7ED3;</h2>
<p>&#x5230;&#x8FD9;&#x5C31;&#x628A; <code>fx</code> &#x57FA;&#x672C;&#x4ECB;&#x7ECD;&#x5B8C;&#x4E86;&#xFF0C;&#x5982;&#x679C;&#x4F60;&#x5BF9;&#x5176;&#x4ED6;API&#x6E90;&#x7801;&#x611F;&#x5174;&#x8DA3;&#xFF0C;&#x53EF;&#x4EE5;&#x8DDF;&#x7740;&#x4E0A;&#x9762;&#x7684; API &#x5217;&#x8868;&#x6328;&#x4E2A;&#x8BFB;&#x4E00;&#x8BFB;&#x3002;</p>
<p>&#x540C;&#x65F6;&#x4E5F;&#x5EFA;&#x8BAE;&#x5927;&#x5BB6;&#x628A; <code>java stream</code> &#x7684;API&#x5927;&#x81F4;&#x770B;&#x770B;&#xFF0C;&#x5BF9;&#x8FD9;&#x79CD; <code>stream call</code> &#x7406;&#x89E3;&#x53EF;&#x4EE5;&#x66F4;&#x52A0;&#x6DF1; &#x3002;</p>
<p>&#x540C;&#x65F6;&#x5728; <code>go-zero</code> &#x4E2D;&#x8FD8;&#x6709;&#x5F88;&#x591A;&#x5B9E;&#x7528;&#x7684;&#x7EC4;&#x4EF6;&#x5DE5;&#x5177;&#xFF0C;&#x7528;&#x597D;&#x5DE5;&#x5177;&#x5BF9;&#x4E8E;&#x63D0;&#x5347;&#x670D;&#x52A1;&#x6027;&#x80FD;&#x548C;&#x5F00;&#x53D1;&#x6548;&#x7387;&#x90FD;&#x6709;&#x5F88;&#x5927;&#x7684;&#x5E2E;&#x52A9;&#xFF0C;&#x5E0C;&#x671B;&#x672C;&#x7BC7;&#x6587;&#x7AE0;&#x80FD;&#x7ED9;&#x5927;&#x5BB6;&#x5E26;&#x6765;&#x4E00;&#x4E9B;&#x6536;&#x83B7;&#x3002;</p>
<h2 id="&#x53C2;&#x8003;&#x8D44;&#x6599;">&#x53C2;&#x8003;&#x8D44;&#x6599;</h2>
<ul>
<li><a href="https://github.com/tal-tech/go-zero" target="_blank">go-zero</a></li>
<li><a href="https://colobu.com/2016/03/02/Java-Stream/" target="_blank">Java Stream &#x8BE6;&#x89E3;</a></li>
<li><a href="https://mp.weixin.qq.com/s/xa98C-QUHRUK0BhWLzI3XQ" target="_blank">Java 8&#x4E2D;Stream API</a></li>
</ul>
<p><link rel="stylesheet" href="https://cdn.jsdelivr.net/npm/gitalk@1/dist/gitalk.css"></p>
<script src="./javascript/gitalk.js"></script>
<div id="gitalk-container"></div>
<script>
var gitalk = new Gitalk({
  "clientID": "b9f61eecd453fb93cefc",
  "clientSecret": "8e70a3944fa689c13136aa56ea5bfb9945802bd2",
  "repo": "go-zero-doc",
  "owner": "zeromicro",
  "admin": ["anqiansong"],
  "id": window.location.pathname,      
  "distractionFreeMode": false  
});
gitalk.render("gitalk-container");
</script>


<footer class="page-footer"><span class="copyright">Copyright &#xA9; 2019-2021 go-zero all right reserved&#xFF0C;powered by Gitbook</span><span class="footer-modification">&#x6700;&#x540E;&#x66F4;&#x65B0;&#x65F6;&#x95F4;&#xFF1A;
2021-04-10 07:21:07
</span></footer>
<script>console.log("plugin-popup....");document.onclick = function(e){ e.target.tagName === "IMG" && window.open(e.target.src,e.target.src)}</script><style>img{cursor:pointer}</style>
                                
                                </section>
                            
    </div>
    <div class="search-results">
        <div class="has-results">
            
            <h1 class="search-results-title"><span class='search-results-count'></span> results matching "<span class='search-query'></span>"</h1>
            <ul class="search-results-list"></ul>
            
        </div>
        <div class="no-results">
            
            <h1 class="search-results-title">No results matching "<span class='search-query'></span>"</h1>
            
        </div>
    </div>
</div>

                        </div>
                    </div>
                
            </div>

            
                <a href="executors.html" class="navigation navigation-prev " aria-label="Previous page: executors">
                    <i class="fa fa-angle-left"></i>
                </a>
                
                
                <a href="mysql.html" class="navigation navigation-next " aria-label="Next page: mysql">
                    <i class="fa fa-angle-right"></i>
                </a>
                
            
    </div>

    <script>
        var gitbook = gitbook || [];
        gitbook.push(function() {
            gitbook.page.hasChanged({"page":{"title":"fx","level":"1.9.4","depth":2,"next":{"title":"mysql","level":"1.9.5","depth":2,"path":"mysql.md","ref":"mysql.md","articles":[]},"previous":{"title":"executors","level":"1.9.3","depth":2,"path":"executors.md","ref":"executors.md","articles":[]},"dir":"ltr"},"config":{"plugins":["back-to-top-button","chapter-fold","code","-lunr","-search","search-pro","github","splitter","-sharing","sharing-plus","tbfed-pagefooter","flexible-alerts","page-toc-button","pageview-count","popup","hide-element","edit-link","-highlight","prism","theme-comscore"],"styles":{"website":"styles/website.css","pdf":"styles/pdf.css","epub":"styles/epub.css","mobi":"styles/mobi.css","ebook":"styles/ebook.css","print":"styles/print.css"},"pluginsConfig":{"tbfed-pagefooter":{"copyright":"Copyright © 2019-2021 go-zero","modify_label":"最后更新时间：","modify_format":"YYYY-MM-DD HH:mm:ss"},"chapter-fold":{},"prism":{"lang":{"shell":"bash"},"css":["prismjs/themes/prism-tomorrow.css"]},"github":{"url":"https://github.com/tal-tech/go-zero"},"splitter":{},"search-pro":{},"sharing-plus":{"qq":false,"all":["facebook","google","twitter","instapaper","linkedin","pocket","stumbleupon"],"douban":false,"facebook":true,"weibo":false,"instapaper":false,"whatsapp":false,"hatenaBookmark":false,"twitter":true,"messenger":false,"line":false,"vk":false,"pocket":true,"google":false,"viber":false,"stumbleupon":false,"qzone":false,"linkedin":false},"popup":{},"code":{"copyButtons":true},"hide-element":{"elements":[".gitbook-link"]},"fontsettings":{"theme":"white","family":"sans","size":2},"theme-comscore":{},"page-toc-button":{"maxTocDepth":2,"minTocSize":2},"back-to-top-button":{},"pageview-count":{},"flexible-alerts":{"danger":{"className":"danger","icon":"fa fa-ban","label":"Attention"},"note":{"className":"info","icon":"fa fa-info-circle","label":"Note"},"style":"callout","tip":{"className":"tip","icon":"fa fa-lightbulb-o","label":"Tip"},"warning":{"className":"warning","icon":"fa fa-exclamation-triangle","label":"Warning"}},"sharing":{"qq":false,"all":["douban","facebook","google","linkedin","twitter","weibo","qq","qzone","weibo"],"douban":false,"facebook":false,"weibo":true,"instapaper":false,"whatsapp":false,"hatenaBookmark":false,"twitter":false,"messenger":false,"line":true,"vk":false,"pocket":false,"google":true,"viber":false,"stumbleupon":false,"qzone":true,"linkedin":true},"edit-link":{"label":"编辑此页","base":"https://github.com/zeromicro/go-zero-doc/blob/master"},"theme-default":{"styles":{"website":"styles/website.css","pdf":"styles/pdf.css","epub":"styles/epub.css","mobi":"styles/mobi.css","ebook":"styles/ebook.css","print":"styles/print.css"},"showLevel":false}},"theme":"default","author":"松妹子","pdf":{"pageNumbers":true,"fontSize":12,"fontFamily":"Arial","paperSize":"a4","chapterMark":"pagebreak","pageBreaksBefore":"/","margin":{"right":62,"left":62,"top":56,"bottom":56}},"structure":{"langs":"LANGS.md","readme":"README.md","glossary":"GLOSSARY.md","summary":"SUMMARY.md"},"variables":{},"title":"go-zero使用文档","language":"zh-hans","gitbook":"3.2.3"},"file":{"path":"fx.md","mtime":"2021-04-10T07:21:07.992Z","type":"markdown"},"gitbook":{"version":"3.2.3","time":"2021-04-10T07:22:08.598Z"},"basePath":".","book":{"language":""}});
        });
    </script>
</div>

        
    <script src="gitbook/gitbook.js"></script>
    <script src="gitbook/theme.js"></script>
    
        
        <script src="gitbook/gitbook-plugin-back-to-top-button/plugin.js"></script>
        
    
        <script src="gitbook/gitbook-plugin-chapter-fold/chapter-fold.js"></script>
        
    
        <script src="gitbook/gitbook-plugin-code/plugin.js"></script>
        
    
        <script src="gitbook/gitbook-plugin-search-pro/jquery.mark.min.js"></script>
        
    
        <script src="gitbook/gitbook-plugin-search-pro/search.js"></script>
        
    
        <script src="gitbook/gitbook-plugin-github/plugin.js"></script>
        
    
        <script src="gitbook/gitbook-plugin-splitter/splitter.js"></script>
        
    
        <script src="gitbook/gitbook-plugin-sharing-plus/buttons.js"></script>
        
    
        <script src="gitbook/gitbook-plugin-flexible-alerts/plugin.js"></script>
        
    
        <script src="gitbook/gitbook-plugin-page-toc-button/plugin.js"></script>
        
    
        <script src="gitbook/gitbook-plugin-pageview-count/plugin.js"></script>
        
    
        <script src="gitbook/gitbook-plugin-hide-element/plugin.js"></script>
        
    
        <script src="gitbook/gitbook-plugin-edit-link/plugin.js"></script>
        
    
        <script src="gitbook/gitbook-plugin-fontsettings/fontsettings.js"></script>
        
    
        <script src="gitbook/gitbook-plugin-theme-comscore/test.js"></script>
        
    
    </body>
</html>