duan1979768678 2013-12-18 19:17
浏览 25
已采纳

如何在Go中将字节推入阅读器?

I need to incrementally append bytes as I receive them to a buffer where I can read them again later. Something like this:

type TwoPassReader struct {
  someDataSource SomeDataReader
  secondPassReader io.Reader
}

func (r *TwoPassReader) Read(b []byte) (n int, err error) {
  n, err := r.someDataSource.Read(b)
  if err == nil {
    //XXX: this doesn't actually exist, right?
    bytesAppended, writeErr := r.secondPassReader.Write(b)
  }
  return n, err
}

func (r *) ReadSecondPass(b []byte) (n int, err error) {
  return r.secondPassReader.Read(b)
}

While the trivial answer for this would be to use bufio.Reader.Peek, I have a SomeDataReader object that I can't modify instead of a Reader. Is the best solution to just put the data into a []byte and return that when ReadSecondPass is called?

  • 写回答

2条回答 默认 最新

  • doudong0425 2013-12-18 22:35
    关注

    Something like this?

    package main
    
    import (
        "bytes"
        "io"
    )
    
    type TwoPassReader struct {
        firstPassReader  io.Reader
        secondPassBuffer io.ReadWriter
    }
    
    func NewTwoPassReader(firstPass io.Reader) *TwoPassReader {
        return &TwoPassReader{
            firstPassReader:  firstPass,
            secondPassBuffer: bytes.NewBuffer(nil),
        }
    }
    
    func (r *TwoPassReader) Read(b []byte) (n int, err error) {
        n1, err1 := r.firstPassReader.Read(b)
        n2, err2 := r.secondPassBuffer.Write(b[:n1])
        if err2 != nil {
            return n2, err2
        }
        return n1, err1
    }
    
    func (r *TwoPassReader) ReadSecondPass(b []byte) (n int, err error) {
        return r.secondPassBuffer.Read(b)
    }
    
    func main() {
    }
    
    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论
查看更多回答(1条)

报告相同问题?

悬赏问题

  • ¥15 拟通过pc下指令到安卓系统,如果追求响应速度,尽可能无延迟,是不是用安卓模拟器会优于实体的安卓手机?如果是,可以快多少毫秒?
  • ¥20 神经网络Sequential name=sequential, built=False
  • ¥16 Qphython 用xlrd读取excel报错
  • ¥15 单片机学习顺序问题!!
  • ¥15 ikuai客户端多拨vpn,重启总是有个别重拨不上
  • ¥20 关于#anlogic#sdram#的问题,如何解决?(关键词-performance)
  • ¥15 相敏解调 matlab
  • ¥15 求lingo代码和思路
  • ¥15 公交车和无人机协同运输
  • ¥15 stm32代码移植没反应