Skip to content

Commit

Permalink
moved read/write simulations to better place
Browse files Browse the repository at this point in the history
  • Loading branch information
jalik committed Aug 20, 2015
1 parent a696e60 commit f7da9eb
Show file tree
Hide file tree
Showing 2 changed files with 10 additions and 6 deletions.
10 changes: 10 additions & 0 deletions ufs-server.js
Original file line number Diff line number Diff line change
Expand Up @@ -87,6 +87,11 @@ if (Meteor.isServer) {
fut.return(file);
}));

// Simulate write speed
if (UploadFS.config.simulateWriteDelay) {
Meteor._sleepForMs(UploadFS.config.simulateWriteDelay);
}

// Execute transformation
store.transformWrite(readStream, writeStream, fileId, file);

Expand Down Expand Up @@ -170,6 +175,11 @@ if (Meteor.isServer) {
return;
}

// Simulate read speed
if (UploadFS.config.simulateReadDelay) {
Meteor._sleepForMs(UploadFS.config.simulateReadDelay);
}

// Get file from database
var fileId = match[2].replace(/\.[^.]+$/, '');
var file = store.getCollection().findOne(fileId);
Expand Down
6 changes: 0 additions & 6 deletions ufs-store.js
Original file line number Diff line number Diff line change
Expand Up @@ -102,9 +102,6 @@ UploadFS.Store = function (options) {
* @param request
*/
self.transformRead = function (from, to, fileId, file, request) {
if (UploadFS.config.simulateReadDelay) {
Meteor._sleepForMs(UploadFS.config.simulateReadDelay);
}
if (typeof transformRead === 'function') {
transformRead.call(self, from, to, fileId, file, request);
} else {
Expand All @@ -120,9 +117,6 @@ UploadFS.Store = function (options) {
* @param file
*/
self.transformWrite = function (from, to, fileId, file) {
if (UploadFS.config.simulateWriteDelay) {
Meteor._sleepForMs(UploadFS.config.simulateWriteDelay);
}
if (typeof transformWrite === 'function') {
transformWrite.call(self, from, to, fileId, file);
} else {
Expand Down

0 comments on commit f7da9eb

Please sign in to comment.