()
| 2263 | } |
| 2264 | |
| 2265 | func (r *natsReader) Read() ([]byte, error) { |
| 2266 | if r.off >= 0 { |
| 2267 | off := r.off |
| 2268 | r.off = -1 |
| 2269 | return r.buf[off:r.n], nil |
| 2270 | } |
| 2271 | var err error |
| 2272 | r.n, err = r.r.Read(r.buf) |
| 2273 | return r.buf[:r.n], err |
| 2274 | } |
| 2275 | |
| 2276 | func (r *natsReader) ReadString(delim byte) (string, error) { |
| 2277 | var s string |
no outgoing calls
no test coverage detected