InitUpstream inits the upstream
(reader io.ReadCloser, writer io.WriteCloser)
| 142 | |
| 143 | // InitUpstream inits the upstream |
| 144 | func (s *Sync) InitUpstream(reader io.ReadCloser, writer io.WriteCloser) error { |
| 145 | upstream, err := newUpstream(reader, writer, s) |
| 146 | if err != nil { |
| 147 | return errors.Wrap(err, "new upstream") |
| 148 | } |
| 149 | |
| 150 | s.upstream = upstream |
| 151 | return nil |
| 152 | } |
| 153 | |
| 154 | // InitDownstream inits the downstream |
| 155 | func (s *Sync) InitDownstream(reader io.ReadCloser, writer io.WriteCloser) error { |