Schließen Strom node.js

Question

ich nicht in der Lage bin einen Strom in node.js zu schließen ist mein Code

 var inp = fs.createReadStream("a/b/c/"+ Name); 
     var out = fs.createWriteStream("a/b/c/"+ Name); 
     inp.pipe(out); 
      inp.close(function(err){ 
       if (err){ 
       console.log(err); 
       } else { 
       inp.unpipe(out); 
       socket.emit('Done',{'Name':name}); 
       console.log('There will be no more data.'); 
       } 
      }); 

Dann habe ich diese Funktion weiter unten in meinem Code, der das Verzeichnis das Verzeichnis von inp löscht

var fse = require("fs-extra"); 
fse.emptyDir("a/b/c/", function(err){ 
    if(err){ 
    console.log(err); 
    } else { 
    console.log("doneaaaa") 
    fse.remove("a/b/c",function(err){ 
     if(err){ 
     console.log(err); 
     } else { 
     console.log('doneaswell'); 
     } 
    }); 
    } 
}); 

und ich bekomme diesen Fehler !!

doneaaaa 
{ [Error: EBUSY: resource busy or locked, unlink 'a/b/c/.nfs000000002ab5000d00000072'] 
    errno: -16, 
    code: 'EBUSY', 
    syscall: 'unlink', 
    path: 'a/b/c/.nfs000000002ab5000d00000072' } 

Das bedeutet, der Stream ist noch offen!

.nfs-Datei wird beim Streaming erstellt richtig, aber sollte Datei nicht löschen, sobald der Stream geschlossen ist?

Was mache ich falsch?

Answer 1

Sie müssen warten, bis der Callback beendet wird, bevor Sie eine Operation zum Entfernen/Entsperren ausführen. Aus den von Ihnen bereitgestellten Samples sieht das nicht so aus.

Answer 2

Node.js läuft async, was bedeutet, dass das Löschen des Verzeichnisses während des Streams erfolgt. Stattdessen versuchen, das Löschen setzt innerhalb der Callback so es occours nach:

var inp = fs.createReadStream("a/b/c/"+ Name); 
var out = fs.createWriteStream("a/b/c/"+ Name); 
inp.pipe(out); 
inp.close(function(err){ 
    if (err){ 
    console.log(err); 
    } else { 
    inp.unpipe(out); 
    socket.emit('Done',{'Name':name}); 
    console.log('There will be no more data.'); 
    } 

    var fse = require("fs-extra"); 
    fse.emptyDir("a/b/c/", function(err){ 
    if(err){ 
     console.log(err); 
    } else { 
     console.log("doneaaaa"); 
     fse.remove("a/b/c",function(err){ 
     if(err){ 
      console.log(err); 
     } else { 
      console.log('doneaswell'); 
     } 
     }); 
    } 
    }); 
}); 

Sie haben auch ein Semikolon in einer Zeile fehlen, die ich auch in diesem Code hinzugefügt :)