code: func (l *Ledis) StoreLogsFromReader(rb io.Reader) error {
  	if !l.ReplicationUsed() {
  		return ErrRplNotSupport
  	} else if !l.cfg.Readonly {
  		return ErrRplInRDWR
  	}
  
  	log := &rpl.Log{}
  
  	for {
  		if err := log.Decode(rb); err != nil {
  			if err == io.EOF {
  				break
  			} else {
  				return err
  			}
  		}
  
  		if err := l.r.StoreLog(log); err != nil {
  			return err
  		}
  
  	}
  
  	l.noticeReplication()
  
  	return nil
  }
docs: // StoreLogsFromReader stores logs from the Reader