diff --git a/mermoria.go b/mermoria.go index 3bb4690..5135aed 100644 --- a/mermoria.go +++ b/mermoria.go @@ -145,11 +145,11 @@ func (m *Memoria) WriteStream(key string, r io.Reader, sync bool) error { return cleanUp(f, fmt.Errorf("Cannot close compression error %s", err)) } - // if sync { - // if err := f.Sync(); err != nil { - // cleanUp(f, fmt.Errorf("Cannot Sync: %s", err)) - // } - // } + if sync { + if err := f.Sync(); err != nil { + cleanUp(f, fmt.Errorf("Cannot Sync: %s", err)) + } + } if err := f.Close(); err != nil { return fmt.Errorf("Cannot close file: %s", err) }