@atlaskit/chunkinator
Advanced tools
Comparing version 3.1.2 to 4.0.0
# Changelog | ||
## 4.0.0 | ||
### Major Changes | ||
- [`bde94d1a336`](https://bitbucket.org/atlassian/atlassian-frontend/commits/bde94d1a336) - When chunkinator has multiple processing batches of chunks, file will only be finalised uploading for once. | ||
## 3.1.2 | ||
@@ -4,0 +10,0 @@ |
@@ -12,2 +12,4 @@ "use strict"; | ||
var _bufferCount = require("rxjs/operators/bufferCount"); | ||
var _fromPromise = require("rxjs/observable/fromPromise"); | ||
@@ -27,2 +29,4 @@ | ||
var _from = require("rxjs/observable/from"); | ||
var getObservableFromFile = function getObservableFromFile(file, options, callbacks) { | ||
@@ -60,3 +64,5 @@ return (0, _fromPromise.fromPromise)((0, _utils.fetchBlob)(file)).pipe((0, _concatMap.concatMap)(function (blob) { | ||
processor: options.processingFunction | ||
}); | ||
}).pipe((0, _concatMap.concatMap)(function (batchedChunks) { | ||
return (0, _from.from)(batchedChunks); | ||
}), (0, _bufferCount.bufferCount)(totalChunks)); | ||
})); | ||
@@ -63,0 +69,0 @@ }; |
{ | ||
"name": "@atlaskit/chunkinator", | ||
"version": "3.1.2", | ||
"version": "4.0.0", | ||
"sideEffects": false | ||
} |
import { tap } from 'rxjs/operators/tap'; | ||
import { concatMap } from 'rxjs/operators/concatMap'; | ||
import { bufferCount } from 'rxjs/operators/bufferCount'; | ||
import { fromPromise } from 'rxjs/observable/fromPromise'; | ||
@@ -10,2 +11,3 @@ import { slicenator } from './slicenator'; | ||
import { fetchBlob } from './utils'; | ||
import { from } from 'rxjs/observable/from'; | ||
export const getObservableFromFile = (file, options, callbacks) => fromPromise(fetchBlob(file)).pipe(concatMap(blob => { | ||
@@ -46,3 +48,5 @@ const { | ||
processor: options.processingFunction | ||
}); | ||
}).pipe(concatMap(batchedChunks => { | ||
return from(batchedChunks); | ||
}), bufferCount(totalChunks)); | ||
})); | ||
@@ -49,0 +53,0 @@ export const chunkinator = (file, options, callbacks) => { |
{ | ||
"name": "@atlaskit/chunkinator", | ||
"version": "3.1.2", | ||
"version": "4.0.0", | ||
"sideEffects": false | ||
} |
import { tap } from 'rxjs/operators/tap'; | ||
import { concatMap } from 'rxjs/operators/concatMap'; | ||
import { bufferCount } from 'rxjs/operators/bufferCount'; | ||
import { fromPromise } from 'rxjs/observable/fromPromise'; | ||
@@ -10,2 +11,3 @@ import { slicenator } from './slicenator'; | ||
import { fetchBlob } from './utils'; | ||
import { from } from 'rxjs/observable/from'; | ||
export var getObservableFromFile = function getObservableFromFile(file, options, callbacks) { | ||
@@ -43,3 +45,5 @@ return fromPromise(fetchBlob(file)).pipe(concatMap(function (blob) { | ||
processor: options.processingFunction | ||
}); | ||
}).pipe(concatMap(function (batchedChunks) { | ||
return from(batchedChunks); | ||
}), bufferCount(totalChunks)); | ||
})); | ||
@@ -46,0 +50,0 @@ }; |
{ | ||
"name": "@atlaskit/chunkinator", | ||
"version": "3.1.2", | ||
"version": "4.0.0", | ||
"sideEffects": false | ||
} |
{ | ||
"name": "@atlaskit/chunkinator", | ||
"version": "3.1.2", | ||
"version": "4.0.0", | ||
"description": "Upload large files from the browser with ease", | ||
@@ -38,4 +38,4 @@ "publishConfig": { | ||
"@atlaskit/docs": "*", | ||
"@atlaskit/media-common": "^2.12.0", | ||
"@atlaskit/media-test-helpers": "^29.4.0", | ||
"@atlaskit/media-common": "^2.13.0", | ||
"@atlaskit/media-test-helpers": "^30.0.0", | ||
"@atlassian/atlassian-frontend-prettier-config-1.0.1": "npm:@atlassian/atlassian-frontend-prettier-config@1.0.1", | ||
@@ -42,0 +42,0 @@ "mockdate": "^3.0.2", |
34875
633