(ctx context.Context, dstDir model.Obj, s model.FileStreamer, up driver.UpdateProgress)
| 114 | } |
| 115 | |
| 116 | func (d *FTPS) Put(ctx context.Context, dstDir model.Obj, s model.FileStreamer, up driver.UpdateProgress) error { |
| 117 | if err := d.login(); err != nil { |
| 118 | return err |
| 119 | } |
| 120 | path := stdpath.Join(dstDir.GetPath(), s.GetName()) |
| 121 | return d.conn.Stor(encode(path, d.Encoding), driver.NewLimitedUploadStream(ctx, &driver.ReaderUpdatingProgress{ |
| 122 | Reader: s, |
| 123 | UpdateProgress: up, |
| 124 | })) |
| 125 | } |
| 126 | |
| 127 | var _ driver.Driver = (*FTPS)(nil) |
nothing calls this directly
no test coverage detected