NewWALDecoder returns a new decoder that reads from rd.
(rd io.Reader)
| 358 | |
| 359 | // NewWALDecoder returns a new decoder that reads from rd. |
| 360 | func NewWALDecoder(rd io.Reader) *WALDecoder { |
| 361 | return &WALDecoder{rd} |
| 362 | } |
| 363 | |
| 364 | // Decode reads the next custom-encoded value from its reader and returns it. |
| 365 | func (dec *WALDecoder) Decode() (*TimedWALMessage, error) { |
no outgoing calls