为什么我的Go Reader不工作?

dan*_*007 4 go

我试图io.Reader在Go中实现一个非常微不足道的事情:

package main

import (
    "io"
    "os"
    "strings"
)

type rot13Reader struct {
    r io.Reader
}

// Very trivial function I implemented.
func (r *rot13Reader) Read(p []byte) (int, error) {
    return 5, nil // Return some trivial values for now.
}

func main() {
    s := strings.NewReader(
        "Lbh penpxrq gur pbqr!")
    r := rot13Reader{s}
    io.Copy(os.Stdout, &r)
}
Run Code Online (Sandbox Code Playgroud)

最后,我想rot13Reader申请ROT13到它读取的字符串,但现在,我只是想创建一个很琐碎io.Reader的适当的接口匹配.

当我运行这个程序时,它永远不会停止.为什么?我在哪里有无限循环?


更新:我尝试data通过下面的for循环改变拼接,但它似乎并没有真正改变拼接.我需要以某种方式复制data吗?

package main

import (

    "io"
    "os"
    "strings"
)

type rot13Reader struct {
    r io.Reader
}

func (r *rot13Reader) Read(data []byte) (int, error) {
    bytesRead, err := r.r.Read(data)

    // Try to alter data... only without this for loop, text prints in standard output... odd.
    for i := 0; i < bytesRead; i++ {
        data[i] += 13   
    }

    return bytesRead, err
}

func main() {
    s := strings.NewReader(
        "Lbh penpxrq gur pbqr!")
    r := rot13Reader{s}
    io.Copy(os.Stdout, &r)
}
Run Code Online (Sandbox Code Playgroud)

Dan*_*iel 8

io.Copy不断调用Read()方法.

来自文档:

"从SRC复制拷贝到dst的,直到达到EOF对Src或出现错误,它返回复制的字节数,并且如果任何复制时遇到,第一误差".

您需要发送EOF或返回错误.

这是一个没有无限循环的更新版本.

http://play.golang.org/p/UCfcw4S8yf

package main

import (
    "io"
    "os"
    "strings"
    "fmt"
)

type rot13Reader struct {
    r io.Reader
}

// Very trivial function I implemented.
func (r *rot13Reader) Read(p []byte) (int, error) {
    return 5, io.EOF // Return some trivial values for now.
}

func main() {
    s := strings.NewReader(
        "Lbh penpxrq gur pbqr!")
    r := rot13Reader{s}
    io.Copy(os.Stdout, &r)
    fmt.Printf("Done copying...\n")
}
Run Code Online (Sandbox Code Playgroud)

如果要将字符串实际复制到输出中.您需要从rot13Reader.r中读取并在Read()方法中将其复制到p.

http://play.golang.org/p/dSCauz0uTw

package main

import (
    "io"
    "os"
    "strings"
    "fmt"
)

type rot13Reader struct {
    r io.Reader
}

// Very trivial function I implemented.
func (r *rot13Reader) Read(p []byte) (int, error) {
    i, err := r.r.Read(p)
    return i, err
}

func main() {
    s := strings.NewReader("Lbh penpxrq gur pbqr!")
    r := rot13Reader{s}
    io.Copy(os.Stdout, &r)
    fmt.Printf("\nDone copying...\n")
}
Run Code Online (Sandbox Code Playgroud)