csjiabin's blog csjiabin's blog
首页
  • 学习笔记

    • 《JavaScript教程》
    • 《JavaScript高级程序设计》
    • 《ES6 教程》
    • 《Vue》
    • 《React》
    • 《TypeScript 从零实现 axios》
  • 学习笔记

    • 《面向Node.js开发者的Go》
更多
  • 分类
  • 标签
  • 归档
GitHub (opens new window)

csjiabin

前端界的小菜鸟
首页
  • 学习笔记

    • 《JavaScript教程》
    • 《JavaScript高级程序设计》
    • 《ES6 教程》
    • 《Vue》
    • 《React》
    • 《TypeScript 从零实现 axios》
  • 学习笔记

    • 《面向Node.js开发者的Go》
更多
  • 分类
  • 标签
  • 归档
GitHub (opens new window)
  • comments
  • printing
  • logging
  • variables
  • interpolation
  • types
  • type check
  • if/else
  • for
  • while
  • switch
  • arrays
  • uint8 arrays
  • array iteration
  • array sorting
  • buffers
  • maps
  • objects
  • functions
  • default values
  • destructuring
  • spread operator
  • rest operator
  • swapping
  • classes
  • generators
  • datetime
  • timeout
  • interval
  • IIFE
  • files
  • json
  • big numbers
  • promises
  • async await
  • streams
    • event emitter
    • errors
    • try/catch
    • exceptions
    • regex
    • exec
    • tcp server
    • udp server
    • http server
    • url parse
    • gzip
    • dns
    • crypto
    • env vars
    • cli args
    • cli flags
    • stdout
    • stderr
    • stdin
    • modules
    • stack trace
    • databases
    • testing
    • benchmarking
    • documentation
    • 《面向Nodejs开发者的Go》
    miguelmota
    2022-09-29
    目录

    streams

    Examples of reading and writing streams

    # Node.js

    const { Readable, Writable } = require("stream");
    
    const inStream = new Readable();
    
    inStream.push(Buffer.from("foo"));
    inStream.push(Buffer.from("bar"));
    inStream.push(null); // end stream
    inStream.pipe(process.stdout);
    
    const outStream = new Writable({
      write(chunk, encoding, callback) {
        console.log("received: " + chunk.toString("utf8"));
        callback();
      },
    });
    
    outStream.write(Buffer.from("abc"));
    outStream.write(Buffer.from("xyz"));
    outStream.end();
    
    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19

    Output

    foobar
    received: abc
    received: xyz
    
    1
    2
    3

    # Go

    package main
    
    import (
    	"bufio"
    	"bytes"
    	"fmt"
    	"io"
    	"os"
    	"runtime"
    )
    
    func main() {
    	inStream := new(bytes.Buffer)
    	w := bufio.NewWriter(inStream)
    	_, err := w.Write([]byte("foo"))
    	if err != nil {
    		panic(err)
    	}
    	_, err = w.Write([]byte("bar"))
    	if err != nil {
    		panic(err)
    	}
    	err = w.Flush()
    	if err != nil {
    		panic(err)
    	}
    
    	inStream.WriteTo(os.Stdout)
    	fmt.Print("\n")
    
    	outStream := new(bytes.Buffer)
    	outStream.Write([]byte("abc\n"))
    	outStream.Write([]byte("xyc\n"))
    	piper, pipew := io.Pipe()
    
    	go func() {
    		sc := bufio.NewScanner(piper)
    		for sc.Scan() {
    			fmt.Println("received: " + sc.Text())
    		}
    		if err := sc.Err(); err != nil {
    			panic(err)
    		}
    
    		os.Exit(0)
    	}()
    
    	go func() {
    		defer pipew.Close()
    		io.Copy(pipew, outStream)
    	}()
    
    	defer runtime.Goexit()
    }
    
    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25
    26
    27
    28
    29
    30
    31
    32
    33
    34
    35
    36
    37
    38
    39
    40
    41
    42
    43
    44
    45
    46
    47
    48
    49
    50
    51
    52
    53
    54

    Output

    foobar
    received: abc
    received: xyc
    
    1
    2
    3

    ⬆ back to top

    编辑 (opens new window)
    #Go#Node.js
    上次更新: 2022/09/30, 11:34:22
    async await
    event emitter

    ← async await event emitter→

    最近更新
    01
    咖啡知识
    10-13
    02
    documentation
    09-29
    03
    benchmarking
    09-29
    更多文章>
    Theme by Vdoing | Copyright © 2018-2022 csjiabin | MIT License
    • 跟随系统
    • 浅色模式
    • 深色模式
    • 阅读模式