@es-git/http-transport - npm Package Compare versions

Comparing version 0.8.4 to 0.9.0

es/commonCapabilities.d.ts

 import { ServerCaps, ClientCaps } from './types';
 export default function commonCapabilities(server: ServerCaps): ClientCaps;
+//# sourceMappingURL=commonCapabilities.d.ts.map

es/composePushRequest.d.ts

@@ -20,1 +20,2 @@ export interface CreateCommand {
 export declare function encodeCommand(command: Command): string;
+//# sourceMappingURL=composePushRequest.d.ts.map

es/composePushRequest.js

@@ -0,11 +1,13 @@
+var __await = (this && this.__await) || function (v) { return this instanceof __await ? (this.v = v, this) : new __await(v); }
 var __asyncValues = (this && this.__asyncValues) || function (o) {
     if (!Symbol.asyncIterator) throw new TypeError("Symbol.asyncIterator is not defined.");
-    var m = o[Symbol.asyncIterator];
-    return m ? m.call(o) : typeof __values === "function" ? __values(o) : o[Symbol.iterator]();
+    var m = o[Symbol.asyncIterator], i;
+    return m ? m.call(o) : (o = typeof __values === "function" ? __values(o) : o[Symbol.iterator](), i = {}, verb("next"), verb("throw"), verb("return"), i[Symbol.asyncIterator] = function () { return this; }, i);
+    function verb(n) { i[n] = o[n] && function (v) { return new Promise(function (resolve, reject) { v = o[n](v), settle(resolve, reject, v.done, v.value); }); }; }
+    function settle(resolve, reject, d, v) { Promise.resolve(v).then(function(v) { resolve({ value: v, done: d }); }, reject); }
 };
-var __await = (this && this.__await) || function (v) { return this instanceof __await ? (this.v = v, this) : new __await(v); }
 var __asyncDelegator = (this && this.__asyncDelegator) || function (o) {
     var i, p;
     return i = {}, verb("next"), verb("throw", function (e) { throw e; }), verb("return"), i[Symbol.iterator] = function () { return this; }, i;
-    function verb(n, f) { if (o[n]) i[n] = function (v) { return (p = !p) ? { value: __await(o[n](v)), done: n === "return" } : f ? f(v) : v; }; }
+    function verb(n, f) { i[n] = o[n] ? function (v) { return (p = !p) ? { value: __await(o[n](v)), done: n === "return" } : f ? f(v) : v; } : f; }
 };
@@ -18,3 +20,3 @@ var __asyncGenerator = (this && this.__asyncGenerator) || function (thisArg, _arguments, generator) {
     function resume(n, v) { try { step(g[n](v)); } catch (e) { settle(q[0][3], e); } }
-    function step(r) { r.value instanceof __await ? Promise.resolve(r.value.v).then(fulfill, reject) : settle(q[0][2], r);  }
+    function step(r) { r.value instanceof __await ? Promise.resolve(r.value.v).then(fulfill, reject) : settle(q[0][2], r); }
     function fulfill(value) { resume("next", value); }
@@ -28,7 +30,7 @@ function reject(value) { resume("throw", value); }
         const [command, ...remainingCommands] = commands;
-        yield pktLine(encodeCommand(command) + '\0report-status side-band-64k agent=es-git');
+        yield yield __await(pktLine(encodeCommand(command) + '\0report-status side-band-64k agent=es-git'));
         for (const command of remainingCommands) {
-            yield pktLine(encodeCommand(command));
+            yield yield __await(pktLine(encodeCommand(command)));
         }
-        yield pktLine(null);
+        yield yield __await(pktLine(null));
         yield __await(yield* __asyncDelegator(__asyncValues(packfile)));
@@ -35,0 +37,0 @@ });

es/composeWantRequest.d.ts

 import { UploadRequest, ClientCaps } from './types';
 export default function composeWantRequest(request: UploadRequest, capabilities: ClientCaps): AsyncIterableIterator<Uint8Array>;
+//# sourceMappingURL=composeWantRequest.d.ts.map

es/composeWantRequest.js

@@ -8,3 +8,3 @@ var __await = (this && this.__await) || function (v) { return this instanceof __await ? (this.v = v, this) : new __await(v); }
     function resume(n, v) { try { step(g[n](v)); } catch (e) { settle(q[0][3], e); } }
-    function step(r) { r.value instanceof __await ? Promise.resolve(r.value.v).then(fulfill, reject) : settle(q[0][2], r);  }
+    function step(r) { r.value instanceof __await ? Promise.resolve(r.value.v).then(fulfill, reject) : settle(q[0][2], r); }
     function fulfill(value) { resume("next", value); }
@@ -18,18 +18,18 @@ function reject(value) { resume("throw", value); }
         const [hash, ...wants] = request.wants;
-        yield pktLine(`want ${hash} ${composeCaps(capabilities)}`);
+        yield yield __await(pktLine(`want ${hash} ${composeCaps(capabilities)}`));
         for (const hash of wants) {
-            yield pktLine(`want ${hash}`);
+            yield yield __await(pktLine(`want ${hash}`));
         }
         for (const shallow of request.shallows) {
-            yield pktLine(`shallow ${shallow}`);
+            yield yield __await(pktLine(`shallow ${shallow}`));
         }
         if (request.depth) {
-            yield pktLine(`deepen ${request.depth}`, false);
+            yield yield __await(pktLine(`deepen ${request.depth}`, false));
         }
-        yield pktLine(null);
+        yield yield __await(pktLine(null));
         for (const hash of request.haves) {
-            yield pktLine(`have ${hash}`);
+            yield yield __await(pktLine(`have ${hash}`));
         }
         if (request.done) {
-            yield pktLine('done');
+            yield yield __await(pktLine('done'));
         }
@@ -36,0 +36,0 @@ });

es/fetch.d.ts

@@ -28,2 +28,3 @@ import { Ref, Hash } from './types';
 }
-export default function fetch({url, fetch, localRefs, refspec, hasObject, depth, shallows, unshallow}: FetchRequest, progress?: Progress): Promise<FetchResult>;
+export default function fetch({ url, fetch, localRefs, refspec, hasObject, depth, shallows, unshallow }: FetchRequest, progress?: Progress): Promise<FetchResult>;
+//# sourceMappingURL=fetch.d.ts.map

es/fetch.js

@@ -8,3 +8,3 @@ var __await = (this && this.__await) || function (v) { return this instanceof __await ? (this.v = v, this) : new __await(v); }
     function resume(n, v) { try { step(g[n](v)); } catch (e) { settle(q[0][3], e); } }
-    function step(r) { r.value instanceof __await ? Promise.resolve(r.value.v).then(fulfill, reject) : settle(q[0][2], r);  }
+    function step(r) { r.value instanceof __await ? Promise.resolve(r.value.v).then(fulfill, reject) : settle(q[0][2], r); }
     function fulfill(value) { resume("next", value); }
@@ -16,4 +16,6 @@ function reject(value) { resume("throw", value); }
     if (!Symbol.asyncIterator) throw new TypeError("Symbol.asyncIterator is not defined.");
-    var m = o[Symbol.asyncIterator];
-    return m ? m.call(o) : typeof __values === "function" ? __values(o) : o[Symbol.iterator]();
+    var m = o[Symbol.asyncIterator], i;
+    return m ? m.call(o) : (o = typeof __values === "function" ? __values(o) : o[Symbol.iterator](), i = {}, verb("next"), verb("throw"), verb("return"), i[Symbol.asyncIterator] = function () { return this; }, i);
+    function verb(n) { i[n] = o[n] && function (v) { return new Promise(function (resolve, reject) { v = o[n](v), settle(resolve, reject, v.done, v.value); }); }; }
+    function settle(resolve, reject, d, v) { Promise.resolve(v).then(function(v) { resolve({ value: v, done: d }); }, reject); }
 };
@@ -23,3 +25,3 @@ var __asyncDelegator = (this && this.__asyncDelegator) || function (o) {
     return i = {}, verb("next"), verb("throw", function (e) { throw e; }), verb("return"), i[Symbol.iterator] = function () { return this; }, i;
-    function verb(n, f) { if (o[n]) i[n] = function (v) { return (p = !p) ? { value: __await(o[n](v)), done: n === "return" } : f ? f(v) : v; }; }
+    function verb(n, f) { i[n] = o[n] ? function (v) { return (p = !p) ? { value: __await(o[n](v)), done: n === "return" } : f ? f(v) : v; } : f; }
 };
@@ -85,7 +87,8 @@ import lsRemote from './lsRemote';
     return __asyncGenerator(this, arguments, function* createResult_1() {
+        var e_1, _a;
         const shallow = [];
         const unshallow = [];
         try {
-            for (var _a = __asyncValues(parsePackResponse(response)), _b; _b = yield __await(_a.next()), !_b.done;) {
-                const parsed = yield __await(_b.value);
+            for (var _b = __asyncValues(parsePackResponse(response)), _c; _c = yield __await(_b.next()), !_c.done;) {
+                const parsed = yield yield __await(__await(_c.value));
                 switch (parsed.type) {
@@ -118,3 +121,3 @@ case 'shallow':
             try {
-                if (_b && !_b.done && (_c = _a.return)) yield __await(_c.call(_a));
+                if (_c && !_c.done && (_a = _b.return)) yield __await(_a.call(_b));
             }
@@ -125,29 +128,4 @@ finally { if (e_1) throw e_1.error; }
         resolveUnshallow(unshallow);
-        var e_1, _c;
     });
 }
-function unpackWithProgress(chunks, progress) {
-    return __asyncGenerator(this, arguments, function* unpackWithProgress_1() {
-        let count = 0;
-        try {
-            for (var _a = __asyncValues(unpack(chunks)), _b; _b = yield __await(_a.next()), !_b.done;) {
-                const object = yield __await(_b.value);
-                count++;
-                if (progress)
-                    progress(`Receiving objects: ?% (${count}/?)\r`);
-                yield object;
-            }
-        }
-        catch (e_2_1) { e_2 = { error: e_2_1 }; }
-        finally {
-            try {
-                if (_b && !_b.done && (_c = _a.return)) yield __await(_c.call(_a));
-            }
-            finally { if (e_2) throw e_2.error; }
-        }
-        if (progress)
-            progress(`Receiving objects: 100% (${count}/${count}), done.\n`);
-        var e_2, _c;
-    });
-}
 //# sourceMappingURL=fetch.js.map

es/fetch.test.d.ts

 export {};
+//# sourceMappingURL=fetch.test.d.ts.map

es/findDifferingRefs.d.ts

@@ -8,1 +8,2 @@ import { Ref, HasObject, RemoteLocalRef } from './types';
 }[]>;
+//# sourceMappingURL=findDifferingRefs.d.ts.map

es/findDifferingRefs.test.d.ts

 export {};
+//# sourceMappingURL=findDifferingRefs.test.d.ts.map

es/index.d.ts

@@ -5,1 +5,2 @@ export { default as fetch, Fetch, RawObject, FetchRequest, FetchResult, RefChange } from './fetch';
 export { Progress } from '@es-git/packfile';
+//# sourceMappingURL=index.d.ts.map

es/lsRemote.d.ts

@@ -14,1 +14,2 @@ import { Ref } from './types';
 export default function lsRemote(url: string, fetch: Fetch, service?: string): Promise<Result>;
+//# sourceMappingURL=lsRemote.d.ts.map

es/lsRemote.test.d.ts

 export {};
+//# sourceMappingURL=lsRemote.test.d.ts.map

es/negotiatePack.d.ts

 import { Hash, UploadRequest } from './types';
 export default function negotiatePack(wants: Hash[], haves: Hash[], shallows?: string[], depth?: number): UploadRequest;
+//# sourceMappingURL=negotiatePack.d.ts.map

es/parsePackResponse.d.ts

@@ -43,1 +43,2 @@ export interface Response {
 export default function parsePackResponse(response: AsyncIterableIterator<Uint8Array>): AsyncIterableIterator<Token>;
+//# sourceMappingURL=parsePackResponse.d.ts.map

es/parsePackResponse.js

@@ -8,3 +8,3 @@ var __await = (this && this.__await) || function (v) { return this instanceof __await ? (this.v = v, this) : new __await(v); }
     function resume(n, v) { try { step(g[n](v)); } catch (e) { settle(q[0][3], e); } }
-    function step(r) { r.value instanceof __await ? Promise.resolve(r.value.v).then(fulfill, reject) : settle(q[0][2], r);  }
+    function step(r) { r.value instanceof __await ? Promise.resolve(r.value.v).then(fulfill, reject) : settle(q[0][2], r); }
     function fulfill(value) { resume("next", value); }
@@ -16,4 +16,6 @@ function reject(value) { resume("throw", value); }
     if (!Symbol.asyncIterator) throw new TypeError("Symbol.asyncIterator is not defined.");
-    var m = o[Symbol.asyncIterator];
-    return m ? m.call(o) : typeof __values === "function" ? __values(o) : o[Symbol.iterator]();
+    var m = o[Symbol.asyncIterator], i;
+    return m ? m.call(o) : (o = typeof __values === "function" ? __values(o) : o[Symbol.iterator](), i = {}, verb("next"), verb("throw"), verb("return"), i[Symbol.asyncIterator] = function () { return this; }, i);
+    function verb(n) { i[n] = o[n] && function (v) { return new Promise(function (resolve, reject) { v = o[n](v), settle(resolve, reject, v.done, v.value); }); }; }
+    function settle(resolve, reject, d, v) { Promise.resolve(v).then(function(v) { resolve({ value: v, done: d }); }, reject); }
 };
@@ -26,3 +28,3 @@ import { AsyncBuffer, decode, fromHex, concat } from '@es-git/core';
     }),
-    'NAK ': async (buffer) => ({
+    'NAK ': async () => ({
         type: 'nak'
@@ -57,3 +59,3 @@ }),
             if (line) {
-                yield yield __await(parseLine(new AsyncBuffer(line)));
+                yield yield __await(yield __await(parseLine(new AsyncBuffer(line))));
             }
@@ -76,2 +78,3 @@ else {
 async function consume(stream) {
+    var e_1, _a;
     const result = [];
@@ -92,3 +95,2 @@ try {
     return concat(...result);
-    var e_1, _a;
 }
@@ -95,0 +97,0 @@ function switchParse(cases) {

es/parsePackResponse.test.d.ts

 export {};
+//# sourceMappingURL=parsePackResponse.test.d.ts.map

es/parseRefsResponse.d.ts

@@ -5,1 +5,2 @@ import { Ref } from './types';
 export declare function parseIdObj(idObj: string): Ref;
+//# sourceMappingURL=parseRefsResponse.d.ts.map

es/parseRefsResponse.test.d.ts

 export {};
+//# sourceMappingURL=parseRefsResponse.test.d.ts.map

es/pkt-line.d.ts

 export default function pktLine(line: Uint8Array | string | null, newline?: boolean): Uint8Array;
+//# sourceMappingURL=pkt-line.d.ts.map

es/pkt-line.test.d.ts

 export {};
+//# sourceMappingURL=pkt-line.test.d.ts.map

es/post.d.ts

@@ -25,1 +25,2 @@ /// <reference types="node" />
 export default function post(url: string, service: string, body: AsyncIterableIterator<Uint8Array>, fetch: Fetch, auth?: Auth): AsyncIterableIterator<Uint8Array>;
+//# sourceMappingURL=post.d.ts.map

es/post.js

 var __await = (this && this.__await) || function (v) { return this instanceof __await ? (this.v = v, this) : new __await(v); }
 var __asyncValues = (this && this.__asyncValues) || function (o) {
     if (!Symbol.asyncIterator) throw new TypeError("Symbol.asyncIterator is not defined.");
-    var m = o[Symbol.asyncIterator];
-    return m ? m.call(o) : typeof __values === "function" ? __values(o) : o[Symbol.iterator]();
+    var m = o[Symbol.asyncIterator], i;
+    return m ? m.call(o) : (o = typeof __values === "function" ? __values(o) : o[Symbol.iterator](), i = {}, verb("next"), verb("throw"), verb("return"), i[Symbol.asyncIterator] = function () { return this; }, i);
+    function verb(n) { i[n] = o[n] && function (v) { return new Promise(function (resolve, reject) { v = o[n](v), settle(resolve, reject, v.done, v.value); }); }; }
+    function settle(resolve, reject, d, v) { Promise.resolve(v).then(function(v) { resolve({ value: v, done: d }); }, reject); }
 };
@@ -10,3 +12,3 @@ var __asyncDelegator = (this && this.__asyncDelegator) || function (o) {
     return i = {}, verb("next"), verb("throw", function (e) { throw e; }), verb("return"), i[Symbol.iterator] = function () { return this; }, i;
-    function verb(n, f) { if (o[n]) i[n] = function (v) { return (p = !p) ? { value: __await(o[n](v)), done: n === "return" } : f ? f(v) : v; }; }
+    function verb(n, f) { i[n] = o[n] ? function (v) { return (p = !p) ? { value: __await(o[n](v)), done: n === "return" } : f ? f(v) : v; } : f; }
 };
@@ -19,3 +21,3 @@ var __asyncGenerator = (this && this.__asyncGenerator) || function (thisArg, _arguments, generator) {
     function resume(n, v) { try { step(g[n](v)); } catch (e) { settle(q[0][3], e); } }
-    function step(r) { r.value instanceof __await ? Promise.resolve(r.value.v).then(fulfill, reject) : settle(q[0][2], r);  }
+    function step(r) { r.value instanceof __await ? Promise.resolve(r.value.v).then(fulfill, reject) : settle(q[0][2], r); }
     function fulfill(value) { resume("next", value); }
@@ -54,5 +56,5 @@ function reject(value) { resume("throw", value); }
     return __asyncGenerator(this, arguments, function* streamify_1() {
-        yield new Uint8Array(yield __await(arrayBuffer));
+        yield yield __await(new Uint8Array(yield __await(arrayBuffer)));
     });
 }
 //# sourceMappingURL=post.js.map

es/push.d.ts

@@ -10,1 +10,2 @@ import { Progress, HashBlob } from '@es-git/packfile';
 export default function push(url: string, fetch: Fetch, commands: Command[], objects: Objects, auth?: Auth, progress?: Progress): Promise<void>;
+//# sourceMappingURL=push.d.ts.map

es/push.js

 var __asyncValues = (this && this.__asyncValues) || function (o) {
     if (!Symbol.asyncIterator) throw new TypeError("Symbol.asyncIterator is not defined.");
-    var m = o[Symbol.asyncIterator];
-    return m ? m.call(o) : typeof __values === "function" ? __values(o) : o[Symbol.iterator]();
+    var m = o[Symbol.asyncIterator], i;
+    return m ? m.call(o) : (o = typeof __values === "function" ? __values(o) : o[Symbol.iterator](), i = {}, verb("next"), verb("throw"), verb("return"), i[Symbol.asyncIterator] = function () { return this; }, i);
+    function verb(n) { i[n] = o[n] && function (v) { return new Promise(function (resolve, reject) { v = o[n](v), settle(resolve, reject, v.done, v.value); }); }; }
+    function settle(resolve, reject, d, v) { Promise.resolve(v).then(function(v) { resolve({ value: v, done: d }); }, reject); }
 };
@@ -11,2 +13,3 @@ import { pack } from '@es-git/packfile';
 export default async function push(url, fetch, commands, objects, auth, progress) {
+    var e_1, _a;
     const packfile = pack(objects.stream, objects.count);
@@ -16,4 +19,4 @@ const body = composePushRequest(packfile, commands);
     try {
-        for (var _a = __asyncValues(parsePackResponse(response)), _b; _b = await _a.next(), !_b.done;) {
-            const parsed = await _b.value;
+        for (var _b = __asyncValues(parsePackResponse(response)), _c; _c = await _b.next(), !_c.done;) {
+            const parsed = await _c.value;
             switch (parsed.type) {
@@ -34,8 +37,7 @@ case 'progress':
         try {
-            if (_b && !_b.done && (_c = _a.return)) await _c.call(_a);
+            if (_c && !_c.done && (_a = _b.return)) await _a.call(_b);
         }
         finally { if (e_1) throw e_1.error; }
     }
-    var e_1, _c;
 }
 //# sourceMappingURL=push.js.map

es/remotesToLocals.d.ts

 import { Ref, RemoteLocalRef } from './types';
 export default function remotesToLocals(remoteRefs: Ref[], refspec: string[]): RemoteLocalRef[];
+//# sourceMappingURL=remotesToLocals.d.ts.map

es/remotesToLocals.test.d.ts

 export {};
+//# sourceMappingURL=remotesToLocals.test.d.ts.map

es/types.d.ts

@@ -35,1 +35,2 @@ export declare type Hash = string;
 export declare type HasObject = (hash: string) => Promise<boolean>;
+//# sourceMappingURL=types.d.ts.map

es/unpkt-line.d.ts

 export declare function unpktLines(content: string): IterableIterator<string>;
 export default function unpktLine(line: string): string[];
 export declare function fromHex(line: string): number;
+//# sourceMappingURL=unpkt-line.d.ts.map

es/unpkt-line.test.d.ts

 export {};
+//# sourceMappingURL=unpkt-line.test.d.ts.map

es/utils/asyncIteratorToBuffer.d.ts

 export default function asyncIteratorToBuffer(iterator: AsyncIterableIterator<Uint8Array>): Promise<ArrayBuffer>;
+//# sourceMappingURL=asyncIteratorToBuffer.d.ts.map

es/utils/asyncIteratorToBuffer.js

 var __asyncValues = (this && this.__asyncValues) || function (o) {
     if (!Symbol.asyncIterator) throw new TypeError("Symbol.asyncIterator is not defined.");
-    var m = o[Symbol.asyncIterator];
-    return m ? m.call(o) : typeof __values === "function" ? __values(o) : o[Symbol.iterator]();
+    var m = o[Symbol.asyncIterator], i;
+    return m ? m.call(o) : (o = typeof __values === "function" ? __values(o) : o[Symbol.iterator](), i = {}, verb("next"), verb("throw"), verb("return"), i[Symbol.asyncIterator] = function () { return this; }, i);
+    function verb(n) { i[n] = o[n] && function (v) { return new Promise(function (resolve, reject) { v = o[n](v), settle(resolve, reject, v.done, v.value); }); }; }
+    function settle(resolve, reject, d, v) { Promise.resolve(v).then(function(v) { resolve({ value: v, done: d }); }, reject); }
 };
 import { concat } from '@es-git/core';
 export default async function asyncIteratorToBuffer(iterator) {
+    var e_1, _a;
     const body = [];
@@ -23,4 +26,3 @@ try {
     return concat(...body).buffer;
-    var e_1, _a;
 }
 //# sourceMappingURL=asyncIteratorToBuffer.js.map

es/utils/asyncIteratorToStream.d.ts

 /// <reference types="node" />
 export default function asyncIteratorToStream(iterator: AsyncIterableIterator<Uint8Array>): ReadableStream | NodeJS.ReadableStream;
+//# sourceMappingURL=asyncIteratorToStream.d.ts.map

es/utils/asyncIteratorToStream.js

 var __asyncValues = (this && this.__asyncValues) || function (o) {
     if (!Symbol.asyncIterator) throw new TypeError("Symbol.asyncIterator is not defined.");
-    var m = o[Symbol.asyncIterator];
-    return m ? m.call(o) : typeof __values === "function" ? __values(o) : o[Symbol.iterator]();
+    var m = o[Symbol.asyncIterator], i;
+    return m ? m.call(o) : (o = typeof __values === "function" ? __values(o) : o[Symbol.iterator](), i = {}, verb("next"), verb("throw"), verb("return"), i[Symbol.asyncIterator] = function () { return this; }, i);
+    function verb(n) { i[n] = o[n] && function (v) { return new Promise(function (resolve, reject) { v = o[n](v), settle(resolve, reject, v.done, v.value); }); }; }
+    function settle(resolve, reject, d, v) { Promise.resolve(v).then(function(v) { resolve({ value: v, done: d }); }, reject); }
 };
@@ -11,2 +13,3 @@ import { Readable } from 'stream';
             async start(controller) {
+                var e_1, _a;
                 try {
@@ -30,3 +33,2 @@ try {
                 }
-                var e_1, _a;
             }
@@ -37,5 +39,6 @@ });
         async _read(size) {
+            var e_2, _a;
             try {
-                for (var _a = __asyncValues(unbreakable(iterator)), _b; _b = await _a.next(), !_b.done;) {
-                    const value = await _b.value;
+                for (var _b = __asyncValues(unbreakable(iterator)), _c; _c = await _b.next(), !_c.done;) {
+                    const value = await _c.value;
                     if (!this.push(value))
@@ -48,3 +51,3 @@ return;
                 try {
-                    if (_b && !_b.done && (_c = _a.return)) await _c.call(_a);
+                    if (_c && !_c.done && (_a = _b.return)) await _a.call(_b);
                 }
@@ -54,3 +57,2 @@ finally { if (e_2) throw e_2.error; }
             this.push(null);
-            var e_2, _c;
         }
@@ -57,0 +59,0 @@ };

es/utils/defer.d.ts

@@ -6,1 +6,2 @@ export default function defer<T>(): {
 };
+//# sourceMappingURL=defer.d.ts.map

es/utils/streamToAsyncIterator.d.ts

 /// <reference types="node" />
 export default function streamToAsyncIterator(readable: NodeJS.ReadableStream | ReadableStream): AsyncIterableIterator<Uint8Array>;
+//# sourceMappingURL=streamToAsyncIterator.d.ts.map

es/utils/streamToAsyncIterator.test.d.ts

 export {};
+//# sourceMappingURL=streamToAsyncIterator.test.d.ts.map

js/composePushRequest.js

@@ -15,2 +15,6 @@ "use strict";
 
+var _iterator2 = require("babel-runtime/core-js/symbol/iterator");
+
+var _iterator3 = _interopRequireDefault(_iterator2);
+
 var _promise = require("babel-runtime/core-js/promise");
@@ -20,6 +24,2 @@
 
-var _iterator2 = require("babel-runtime/core-js/symbol/iterator");
-
-var _iterator3 = _interopRequireDefault(_iterator2);
-
 var _getIterator2 = require("babel-runtime/core-js/get-iterator");
@@ -42,10 +42,25 @@
 
+var __await = undefined && undefined.__await || function (v) {
+    return this instanceof __await ? (this.v = v, this) : new __await(v);
+};
 var __asyncValues = undefined && undefined.__asyncValues || function (o) {
     if (!_symbol2.default.asyncIterator) throw new TypeError("Symbol.asyncIterator is not defined.");
-    var m = o[_symbol2.default.asyncIterator];
-    return m ? m.call(o) : typeof __values === "function" ? __values(o) : (0, _getIterator3.default)(o);
+    var m = o[_symbol2.default.asyncIterator],
+        i;
+    return m ? m.call(o) : (o = typeof __values === "function" ? __values(o) : (0, _getIterator3.default)(o), i = {}, verb("next"), verb("throw"), verb("return"), i[_symbol2.default.asyncIterator] = function () {
+        return this;
+    }, i);
+    function verb(n) {
+        i[n] = o[n] && function (v) {
+            return new _promise2.default(function (resolve, reject) {
+                v = o[n](v), settle(resolve, reject, v.done, v.value);
+            });
+        };
+    }
+    function settle(resolve, reject, d, v) {
+        _promise2.default.resolve(v).then(function (v) {
+            resolve({ value: v, done: d });
+        }, reject);
+    }
 };
-var __await = undefined && undefined.__await || function (v) {
-    return this instanceof __await ? (this.v = v, this) : new __await(v);
-};
 var __asyncDelegator = undefined && undefined.__asyncDelegator || function (o) {
@@ -59,5 +74,5 @@ var i, p;
     function verb(n, f) {
-        if (o[n]) i[n] = function (v) {
+        i[n] = o[n] ? function (v) {
             return (p = !p) ? { value: __await(o[n](v)), done: n === "return" } : f ? f(v) : v;
-        };
+        } : f;
     }
@@ -110,14 +125,18 @@ };
                         _context.next = 3;
-                        return (0, _pktLine2.default)(encodeCommand(command) + '\0report-status side-band-64k agent=es-git');
+                        return __await((0, _pktLine2.default)(encodeCommand(command) + '\0report-status side-band-64k agent=es-git'));
 
                     case 3:
+                        _context.next = 5;
+                        return _context.sent;
+
+                    case 5:
                         _iteratorNormalCompletion = true;
                         _didIteratorError = false;
                         _iteratorError = undefined;
-                        _context.prev = 6;
+                        _context.prev = 8;
                         _iterator = (0, _getIterator3.default)(remainingCommands);
 
-                    case 8:
+                    case 10:
                         if (_iteratorNormalCompletion = (_step = _iterator.next()).done) {
-                            _context.next = 15;
+                            _context.next = 19;
                             break;
@@ -127,23 +146,27 @@ }
                         _command = _step.value;
-                        _context.next = 12;
-                        return (0, _pktLine2.default)(encodeCommand(_command));
+                        _context.next = 14;
+                        return __await((0, _pktLine2.default)(encodeCommand(_command)));
 
-                    case 12:
+                    case 14:
+                        _context.next = 16;
+                        return _context.sent;
+
+                    case 16:
                         _iteratorNormalCompletion = true;
-                        _context.next = 8;
+                        _context.next = 10;
                         break;
 
-                    case 15:
-                        _context.next = 21;
+                    case 19:
+                        _context.next = 25;
                         break;
 
-                    case 17:
-                        _context.prev = 17;
-                        _context.t0 = _context["catch"](6);
+                    case 21:
+                        _context.prev = 21;
+                        _context.t0 = _context["catch"](8);
                         _didIteratorError = true;
                         _iteratorError = _context.t0;
 
-                    case 21:
-                        _context.prev = 21;
-                        _context.prev = 22;
+                    case 25:
+                        _context.prev = 25;
+                        _context.prev = 26;
 
@@ -154,7 +177,7 @@ if (!_iteratorNormalCompletion && _iterator.return) {
 
-                    case 24:
-                        _context.prev = 24;
+                    case 28:
+                        _context.prev = 28;
 
                         if (!_didIteratorError) {
-                            _context.next = 27;
+                            _context.next = 31;
                             break;
@@ -165,22 +188,26 @@ }
 
-                    case 27:
-                        return _context.finish(24);
+                    case 31:
+                        return _context.finish(28);
 
-                    case 28:
-                        return _context.finish(21);
+                    case 32:
+                        return _context.finish(25);
 
-                    case 29:
-                        _context.next = 31;
-                        return (0, _pktLine2.default)(null);
+                    case 33:
+                        _context.next = 35;
+                        return __await((0, _pktLine2.default)(null));
 
-                    case 31:
+                    case 35:
+                        _context.next = 37;
+                        return _context.sent;
+
+                    case 37:
                         _context.t1 = __await;
-                        return _context.delegateYield(__asyncDelegator(__asyncValues(packfile)), "t2", 33);
+                        return _context.delegateYield(__asyncDelegator(__asyncValues(packfile)), "t2", 39);
 
-                    case 33:
+                    case 39:
                         _context.t3 = _context.t2;
-                        _context.next = 36;
+                        _context.next = 42;
                         return (0, _context.t1)(_context.t3);
 
-                    case 36:
+                    case 42:
                     case "end":
@@ -190,3 +217,3 @@ return _context.stop();
             }
-        }, composePushRequest_1, this, [[6, 17, 21, 29], [22,, 24, 28]]);
+        }, composePushRequest_1, this, [[8, 21, 25, 33], [26,, 28, 32]]);
     }));
@@ -193,0 +220,0 @@ }

js/composeWantRequest.js

@@ -91,14 +91,18 @@ "use strict";
                         _context.next = 3;
-                        return (0, _pktLine2.default)("want " + String(hash) + " " + String(composeCaps(capabilities)));
+                        return __await((0, _pktLine2.default)("want " + String(hash) + " " + String(composeCaps(capabilities))));
 
                     case 3:
+                        _context.next = 5;
+                        return _context.sent;
+
+                    case 5:
                         _iteratorNormalCompletion = true;
                         _didIteratorError = false;
                         _iteratorError = undefined;
-                        _context.prev = 6;
+                        _context.prev = 8;
                         _iterator = (0, _getIterator3.default)(wants);
 
-                    case 8:
+                    case 10:
                         if (_iteratorNormalCompletion = (_step = _iterator.next()).done) {
-                            _context.next = 15;
+                            _context.next = 19;
                             break;
@@ -108,23 +112,27 @@ }
                         _hash = _step.value;
-                        _context.next = 12;
-                        return (0, _pktLine2.default)("want " + String(_hash));
+                        _context.next = 14;
+                        return __await((0, _pktLine2.default)("want " + String(_hash)));
 
-                    case 12:
+                    case 14:
+                        _context.next = 16;
+                        return _context.sent;
+
+                    case 16:
                         _iteratorNormalCompletion = true;
-                        _context.next = 8;
+                        _context.next = 10;
                         break;
 
-                    case 15:
-                        _context.next = 21;
+                    case 19:
+                        _context.next = 25;
                         break;
 
-                    case 17:
-                        _context.prev = 17;
-                        _context.t0 = _context["catch"](6);
+                    case 21:
+                        _context.prev = 21;
+                        _context.t0 = _context["catch"](8);
                         _didIteratorError = true;
                         _iteratorError = _context.t0;
 
-                    case 21:
-                        _context.prev = 21;
-                        _context.prev = 22;
+                    case 25:
+                        _context.prev = 25;
+                        _context.prev = 26;
 
@@ -135,7 +143,7 @@ if (!_iteratorNormalCompletion && _iterator.return) {
 
-                    case 24:
-                        _context.prev = 24;
+                    case 28:
+                        _context.prev = 28;
 
                         if (!_didIteratorError) {
-                            _context.next = 27;
+                            _context.next = 31;
                             break;
@@ -146,18 +154,18 @@ }
 
-                    case 27:
-                        return _context.finish(24);
+                    case 31:
+                        return _context.finish(28);
 
-                    case 28:
-                        return _context.finish(21);
+                    case 32:
+                        return _context.finish(25);
 
-                    case 29:
+                    case 33:
                         _iteratorNormalCompletion2 = true;
                         _didIteratorError2 = false;
                         _iteratorError2 = undefined;
-                        _context.prev = 32;
+                        _context.prev = 36;
                         _iterator2 = (0, _getIterator3.default)(request.shallows);
 
-                    case 34:
+                    case 38:
                         if (_iteratorNormalCompletion2 = (_step2 = _iterator2.next()).done) {
-                            _context.next = 41;
+                            _context.next = 47;
                             break;
@@ -167,23 +175,27 @@ }
                         shallow = _step2.value;
-                        _context.next = 38;
-                        return (0, _pktLine2.default)("shallow " + String(shallow));
+                        _context.next = 42;
+                        return __await((0, _pktLine2.default)("shallow " + String(shallow)));
 
-                    case 38:
+                    case 42:
+                        _context.next = 44;
+                        return _context.sent;
+
+                    case 44:
                         _iteratorNormalCompletion2 = true;
-                        _context.next = 34;
+                        _context.next = 38;
                         break;
 
-                    case 41:
-                        _context.next = 47;
+                    case 47:
+                        _context.next = 53;
                         break;
 
-                    case 43:
-                        _context.prev = 43;
-                        _context.t1 = _context["catch"](32);
+                    case 49:
+                        _context.prev = 49;
+                        _context.t1 = _context["catch"](36);
                         _didIteratorError2 = true;
                         _iteratorError2 = _context.t1;
 
-                    case 47:
-                        _context.prev = 47;
-                        _context.prev = 48;
+                    case 53:
+                        _context.prev = 53;
+                        _context.prev = 54;
 
@@ -194,7 +206,7 @@ if (!_iteratorNormalCompletion2 && _iterator2.return) {
 
-                    case 50:
-                        _context.prev = 50;
+                    case 56:
+                        _context.prev = 56;
 
                         if (!_didIteratorError2) {
-                            _context.next = 53;
+                            _context.next = 59;
                             break;
@@ -205,31 +217,39 @@ }
 
-                    case 53:
-                        return _context.finish(50);
+                    case 59:
+                        return _context.finish(56);
 
-                    case 54:
-                        return _context.finish(47);
+                    case 60:
+                        return _context.finish(53);
 
-                    case 55:
+                    case 61:
                         if (!request.depth) {
-                            _context.next = 58;
+                            _context.next = 66;
                             break;
                         }
 
-                        _context.next = 58;
-                        return (0, _pktLine2.default)("deepen " + String(request.depth), false);
+                        _context.next = 64;
+                        return __await((0, _pktLine2.default)("deepen " + String(request.depth), false));
 
-                    case 58:
-                        _context.next = 60;
-                        return (0, _pktLine2.default)(null);
+                    case 64:
+                        _context.next = 66;
+                        return _context.sent;
 
-                    case 60:
+                    case 66:
+                        _context.next = 68;
+                        return __await((0, _pktLine2.default)(null));
+
+                    case 68:
+                        _context.next = 70;
+                        return _context.sent;
+
+                    case 70:
                         _iteratorNormalCompletion3 = true;
                         _didIteratorError3 = false;
                         _iteratorError3 = undefined;
-                        _context.prev = 63;
+                        _context.prev = 73;
                         _iterator3 = (0, _getIterator3.default)(request.haves);
 
-                    case 65:
+                    case 75:
                         if (_iteratorNormalCompletion3 = (_step3 = _iterator3.next()).done) {
-                            _context.next = 72;
+                            _context.next = 84;
                             break;
@@ -239,23 +259,27 @@ }
                         _hash2 = _step3.value;
-                        _context.next = 69;
-                        return (0, _pktLine2.default)("have " + String(_hash2));
+                        _context.next = 79;
+                        return __await((0, _pktLine2.default)("have " + String(_hash2)));
 
-                    case 69:
+                    case 79:
+                        _context.next = 81;
+                        return _context.sent;
+
+                    case 81:
                         _iteratorNormalCompletion3 = true;
-                        _context.next = 65;
+                        _context.next = 75;
                         break;
 
-                    case 72:
-                        _context.next = 78;
+                    case 84:
+                        _context.next = 90;
                         break;
 
-                    case 74:
-                        _context.prev = 74;
-                        _context.t2 = _context["catch"](63);
+                    case 86:
+                        _context.prev = 86;
+                        _context.t2 = _context["catch"](73);
                         _didIteratorError3 = true;
                         _iteratorError3 = _context.t2;
 
-                    case 78:
-                        _context.prev = 78;
-                        _context.prev = 79;
+                    case 90:
+                        _context.prev = 90;
+                        _context.prev = 91;
 
@@ -266,7 +290,7 @@ if (!_iteratorNormalCompletion3 && _iterator3.return) {
 
-                    case 81:
-                        _context.prev = 81;
+                    case 93:
+                        _context.prev = 93;
 
                         if (!_didIteratorError3) {
-                            _context.next = 84;
+                            _context.next = 96;
                             break;
@@ -277,18 +301,22 @@ }
 
-                    case 84:
-                        return _context.finish(81);
+                    case 96:
+                        return _context.finish(93);
 
-                    case 85:
-                        return _context.finish(78);
+                    case 97:
+                        return _context.finish(90);
 
-                    case 86:
+                    case 98:
                         if (!request.done) {
-                            _context.next = 89;
+                            _context.next = 103;
                             break;
                         }
 
-                        _context.next = 89;
-                        return (0, _pktLine2.default)('done');
+                        _context.next = 101;
+                        return __await((0, _pktLine2.default)('done'));
 
-                    case 89:
+                    case 101:
+                        _context.next = 103;
+                        return _context.sent;
+
+                    case 103:
                     case "end":
@@ -298,3 +326,3 @@ return _context.stop();
             }
-        }, composeWantRequest_1, this, [[6, 17, 21, 29], [22,, 24, 28], [32, 43, 47, 55], [48,, 50, 54], [63, 74, 78, 86], [79,, 81, 85]]);
+        }, composeWantRequest_1, this, [[8, 21, 25, 33], [26,, 28, 32], [36, 49, 53, 61], [54,, 56, 60], [73, 86, 90, 98], [91,, 93, 97]]);
     }));
@@ -301,0 +329,0 @@ }

js/fetch.js

@@ -167,4 +167,19 @@ "use strict";
     if (!_symbol2.default.asyncIterator) throw new TypeError("Symbol.asyncIterator is not defined.");
-    var m = o[_symbol2.default.asyncIterator];
-    return m ? m.call(o) : typeof __values === "function" ? __values(o) : (0, _getIterator3.default)(o);
+    var m = o[_symbol2.default.asyncIterator],
+        i;
+    return m ? m.call(o) : (o = typeof __values === "function" ? __values(o) : (0, _getIterator3.default)(o), i = {}, verb("next"), verb("throw"), verb("return"), i[_symbol2.default.asyncIterator] = function () {
+        return this;
+    }, i);
+    function verb(n) {
+        i[n] = o[n] && function (v) {
+            return new _promise2.default(function (resolve, reject) {
+                v = o[n](v), settle(resolve, reject, v.done, v.value);
+            });
+        };
+    }
+    function settle(resolve, reject, d, v) {
+        _promise2.default.resolve(v).then(function (v) {
+            resolve({ value: v, done: d });
+        }, reject);
+    }
 };
@@ -179,5 +194,5 @@ var __asyncDelegator = undefined && undefined.__asyncDelegator || function (o) {
     function verb(n, f) {
-        if (o[n]) i[n] = function (v) {
+        i[n] = o[n] ? function (v) {
             return (p = !p) ? { value: __await(o[n](v)), done: n === "return" } : f ? f(v) : v;
-        };
+        } : f;
     }
@@ -292,3 +307,3 @@ };
     return __asyncGenerator(this, arguments, /*#__PURE__*/_regenerator2.default.mark(function createResult_1() {
-        var shallow, unshallow, _a, _b, parsed, e_1, _c;
+        var e_1, _a, shallow, unshallow, _b, _c, parsed;
 
@@ -302,13 +317,13 @@ return _regenerator2.default.wrap(function createResult_1$(_context4) {
                         _context4.prev = 2;
-                        _a = __asyncValues((0, _parsePackResponse2.default)(response));
+                        _b = __asyncValues((0, _parsePackResponse2.default)(response));
 
                     case 4:
                         _context4.next = 6;
-                        return __await(_a.next());
+                        return __await(_b.next());
 
                     case 6:
-                        _b = _context4.sent;
+                        _c = _context4.sent;
 
-                        if (_b.done) {
-                            _context4.next = 31;
+                        if (_c.done) {
+                            _context4.next = 33;
                             break;
@@ -318,71 +333,75 @@ }
                         _context4.next = 10;
-                        return __await(_b.value);
+                        return __await(__await(_c.value));
 
                     case 10:
+                        _context4.next = 12;
+                        return _context4.sent;
+
+                    case 12:
                         parsed = _context4.sent;
                         _context4.t0 = parsed.type;
-                        _context4.next = _context4.t0 === 'shallow' ? 14 : _context4.t0 === 'unshallow' ? 16 : _context4.t0 === 'ack' ? 18 : _context4.t0 === 'nak' ? 18 : _context4.t0 === 'pack' ? 19 : _context4.t0 === 'progress' ? 25 : _context4.t0 === 'error' ? 27 : 29;
+                        _context4.next = _context4.t0 === 'shallow' ? 16 : _context4.t0 === 'unshallow' ? 18 : _context4.t0 === 'ack' ? 20 : _context4.t0 === 'nak' ? 20 : _context4.t0 === 'pack' ? 21 : _context4.t0 === 'progress' ? 27 : _context4.t0 === 'error' ? 29 : 31;
                         break;
 
-                    case 14:
+                    case 16:
                         shallow.push(parsed.hash);
-                        return _context4.abrupt("break", 29);
+                        return _context4.abrupt("break", 31);
 
-                    case 16:
+                    case 18:
                         unshallow.push(parsed.hash);
-                        return _context4.abrupt("break", 29);
+                        return _context4.abrupt("break", 31);
 
-                    case 18:
-                        return _context4.abrupt("break", 29);
+                    case 20:
+                        return _context4.abrupt("break", 31);
 
-                    case 19:
+                    case 21:
                         _context4.t1 = __await;
-                        return _context4.delegateYield(__asyncDelegator(__asyncValues(parsed.chunks)), "t2", 21);
+                        return _context4.delegateYield(__asyncDelegator(__asyncValues(parsed.chunks)), "t2", 23);
 
-                    case 21:
+                    case 23:
                         _context4.t3 = _context4.t2;
-                        _context4.next = 24;
+                        _context4.next = 26;
                         return (0, _context4.t1)(_context4.t3);
 
-                    case 24:
-                        return _context4.abrupt("break", 29);
+                    case 26:
+                        return _context4.abrupt("break", 31);
 
-                    case 25:
+                    case 27:
                         if (progress) progress(parsed.message);
-                        return _context4.abrupt("break", 29);
+                        return _context4.abrupt("break", 31);
 
-                    case 27:
+                    case 29:
                         if (progress) progress(parsed.message);
-                        return _context4.abrupt("break", 29);
+                        return _context4.abrupt("break", 31);
 
-                    case 29:
+                    case 31:
                         _context4.next = 4;
                         break;
 
-                    case 31:
-                        _context4.next = 36;
+                    case 33:
+                        _context4.next = 38;
                         break;
 
-                    case 33:
-                        _context4.prev = 33;
+                    case 35:
+                        _context4.prev = 35;
                         _context4.t4 = _context4["catch"](2);
                         e_1 = { error: _context4.t4 };
 
-                    case 36:
-                        _context4.prev = 36;
-                        _context4.prev = 37;
+                    case 38:
+                        _context4.prev = 38;
+                        _context4.prev = 39;
 
-                        if (!(_b && !_b.done && (_c = _a.return))) {
-                            _context4.next = 41;
+                        if (!(_c && !_c.done && (_a = _b.return))) {
+                            _context4.next = 43;
                             break;
                         }
 
-                        _context4.next = 41;
-                        return __await(_c.call(_a));
+                        _context4.next = 43;
+                        return __await(_a.call(_b));
 
-                    case 41:
-                        _context4.prev = 41;
+                    case 43:
+                        _context4.prev = 43;
 
                         if (!e_1) {
-                            _context4.next = 44;
+                            _context4.next = 46;
                             break;
@@ -393,13 +412,13 @@ }
 
-                    case 44:
-                        return _context4.finish(41);
+                    case 46:
+                        return _context4.finish(43);
 
-                    case 45:
-                        return _context4.finish(36);
+                    case 47:
+                        return _context4.finish(38);
 
-                    case 46:
+                    case 48:
                         resolveShallow(shallow);
                         resolveUnshallow(unshallow);
 
-                    case 48:
+                    case 50:
                     case "end":
@@ -409,93 +428,6 @@ return _context4.stop();
             }
-        }, createResult_1, this, [[2, 33, 36, 46], [37,, 41, 45]]);
+        }, createResult_1, this, [[2, 35, 38, 48], [39,, 43, 47]]);
     }));
 }
-function unpackWithProgress(chunks, progress) {
-    return __asyncGenerator(this, arguments, /*#__PURE__*/_regenerator2.default.mark(function unpackWithProgress_1() {
-        var count, _a, _b, object, e_2, _c;
-
-        return _regenerator2.default.wrap(function unpackWithProgress_1$(_context5) {
-            while (1) {
-                switch (_context5.prev = _context5.next) {
-                    case 0:
-                        count = 0;
-                        _context5.prev = 1;
-                        _a = __asyncValues((0, _packfile.unpack)(chunks));
-
-                    case 3:
-                        _context5.next = 5;
-                        return __await(_a.next());
-
-                    case 5:
-                        _b = _context5.sent;
-
-                        if (_b.done) {
-                            _context5.next = 16;
-                            break;
-                        }
-
-                        _context5.next = 9;
-                        return __await(_b.value);
-
-                    case 9:
-                        object = _context5.sent;
-
-                        count++;
-                        if (progress) progress("Receiving objects: ?% (" + count + "/?)\r");
-                        _context5.next = 14;
-                        return object;
-
-                    case 14:
-                        _context5.next = 3;
-                        break;
-
-                    case 16:
-                        _context5.next = 21;
-                        break;
-
-                    case 18:
-                        _context5.prev = 18;
-                        _context5.t0 = _context5["catch"](1);
-                        e_2 = { error: _context5.t0 };
-
-                    case 21:
-                        _context5.prev = 21;
-                        _context5.prev = 22;
-
-                        if (!(_b && !_b.done && (_c = _a.return))) {
-                            _context5.next = 26;
-                            break;
-                        }
-
-                        _context5.next = 26;
-                        return __await(_c.call(_a));
-
-                    case 26:
-                        _context5.prev = 26;
-
-                        if (!e_2) {
-                            _context5.next = 29;
-                            break;
-                        }
-
-                        throw e_2.error;
-
-                    case 29:
-                        return _context5.finish(26);
-
-                    case 30:
-                        return _context5.finish(21);
-
-                    case 31:
-                        if (progress) progress("Receiving objects: 100% (" + count + "/" + count + "), done.\n");
-
-                    case 32:
-                    case "end":
-                        return _context5.stop();
-                }
-            }
-        }, unpackWithProgress_1, this, [[1, 18, 21, 31], [22,, 26, 30]]);
-    }));
-}
 //# sourceMappingURL=fetch.js.map
 //# sourceMappingURL=fetch.js.map

js/parsePackResponse.js

@@ -70,3 +70,3 @@ "use strict";
 
-    return function unpktLine(_x8) {
+    return function unpktLine(_x7) {
         return _ref8.apply(this, arguments);
@@ -80,3 +80,3 @@ };
     var _ref9 = (0, _asyncToGenerator3.default)( /*#__PURE__*/_regenerator2.default.mark(function _callee9(stream) {
-        var result, stream_1, stream_1_1, chunk, e_1, _a;
+        var e_1, _a, result, stream_1, stream_1_1, chunk;
 
@@ -163,3 +163,3 @@ return _regenerator2.default.wrap(function _callee9$(_context10) {
 
-    return function consume(_x9) {
+    return function consume(_x8) {
         return _ref9.apply(this, arguments);
@@ -215,4 +215,19 @@ };
     if (!_symbol2.default.asyncIterator) throw new TypeError("Symbol.asyncIterator is not defined.");
-    var m = o[_symbol2.default.asyncIterator];
-    return m ? m.call(o) : typeof __values === "function" ? __values(o) : (0, _getIterator3.default)(o);
+    var m = o[_symbol2.default.asyncIterator],
+        i;
+    return m ? m.call(o) : (o = typeof __values === "function" ? __values(o) : (0, _getIterator3.default)(o), i = {}, verb("next"), verb("throw"), verb("return"), i[_symbol2.default.asyncIterator] = function () {
+        return this;
+    }, i);
+    function verb(n) {
+        i[n] = o[n] && function (v) {
+            return new _promise2.default(function (resolve, reject) {
+                v = o[n](v), settle(resolve, reject, v.done, v.value);
+            });
+        };
+    }
+    function settle(resolve, reject, d, v) {
+        _promise2.default.resolve(v).then(function (v) {
+            resolve({ value: v, done: d });
+        }, reject);
+    }
 };
@@ -256,3 +271,3 @@
 
-        var _ref2 = (0, _asyncToGenerator3.default)( /*#__PURE__*/_regenerator2.default.mark(function _callee2(buffer) {
+        var _ref2 = (0, _asyncToGenerator3.default)( /*#__PURE__*/_regenerator2.default.mark(function _callee2() {
             return _regenerator2.default.wrap(function _callee2$(_context2) {
@@ -274,3 +289,3 @@ while (1) {
 
-        return function NAK(_x2) {
+        return function NAK() {
             return _ref2.apply(this, arguments);
@@ -307,3 +322,3 @@ };
 
-        return function shallow(_x3) {
+        return function shallow(_x2) {
             return _ref3.apply(this, arguments);
@@ -340,3 +355,3 @@ };
 
-        return function unshallow(_x4) {
+        return function unshallow(_x3) {
             return _ref4.apply(this, arguments);
@@ -366,3 +381,3 @@ };
 
-        return function _(_x5) {
+        return function _(_x4) {
             return _ref5.apply(this, arguments);
@@ -399,3 +414,3 @@ };
 
-        return function _(_x6) {
+        return function _(_x5) {
             return _ref6.apply(this, arguments);
@@ -432,3 +447,3 @@ };
 
-        return function _(_x7) {
+        return function _(_x6) {
             return _ref7.apply(this, arguments);
@@ -449,3 +464,3 @@ };
                         if (!true) {
-                            _context8.next = 18;
+                            _context8.next = 22;
                             break;
@@ -461,34 +476,40 @@ }
                         if (!line) {
-                            _context8.next = 12;
+                            _context8.next = 16;
                             break;
                         }
 
-                        _context8.next = 8;
+                        _context8.t0 = __await;
+                        _context8.next = 9;
                         return __await(parseLine(new _core.AsyncBuffer(line)));
 
-                    case 8:
-                        _context8.next = 10;
+                    case 9:
+                        _context8.t1 = _context8.sent;
+                        _context8.next = 12;
+                        return (0, _context8.t0)(_context8.t1);
+
+                    case 12:
+                        _context8.next = 14;
                         return _context8.sent;
 
-                    case 10:
-                        _context8.next = 16;
+                    case 14:
+                        _context8.next = 20;
                         break;
 
-                    case 12:
-                        _context8.next = 14;
+                    case 16:
+                        _context8.next = 18;
                         return __await(buffer.isDone());
 
-                    case 14:
+                    case 18:
                         if (!_context8.sent) {
-                            _context8.next = 16;
+                            _context8.next = 20;
                             break;
                         }
 
-                        return _context8.abrupt("break", 18);
+                        return _context8.abrupt("break", 22);
 
-                    case 16:
+                    case 20:
                         _context8.next = 1;
                         break;
 
-                    case 18:
+                    case 22:
                     case "end":
@@ -551,3 +572,3 @@ return _context8.stop();
 
-        return function (_x10) {
+        return function (_x9) {
             return _ref11.apply(this, arguments);
@@ -582,3 +603,3 @@ };
 
-        return function (_x11) {
+        return function (_x10) {
             return _ref12.apply(this, arguments);
@@ -585,0 +606,0 @@ };

js/post.js

@@ -15,2 +15,6 @@ "use strict";
 
+var _iterator = require("babel-runtime/core-js/symbol/iterator");
+
+var _iterator2 = _interopRequireDefault(_iterator);
+
 var _promise = require("babel-runtime/core-js/promise");
@@ -20,6 +24,2 @@
 
-var _iterator = require("babel-runtime/core-js/symbol/iterator");
-
-var _iterator2 = _interopRequireDefault(_iterator);
-
 var _getIterator2 = require("babel-runtime/core-js/get-iterator");
@@ -50,4 +50,19 @@
     if (!_symbol2.default.asyncIterator) throw new TypeError("Symbol.asyncIterator is not defined.");
-    var m = o[_symbol2.default.asyncIterator];
-    return m ? m.call(o) : typeof __values === "function" ? __values(o) : (0, _getIterator3.default)(o);
+    var m = o[_symbol2.default.asyncIterator],
+        i;
+    return m ? m.call(o) : (o = typeof __values === "function" ? __values(o) : (0, _getIterator3.default)(o), i = {}, verb("next"), verb("throw"), verb("return"), i[_symbol2.default.asyncIterator] = function () {
+        return this;
+    }, i);
+    function verb(n) {
+        i[n] = o[n] && function (v) {
+            return new _promise2.default(function (resolve, reject) {
+                v = o[n](v), settle(resolve, reject, v.done, v.value);
+            });
+        };
+    }
+    function settle(resolve, reject, d, v) {
+        _promise2.default.resolve(v).then(function (v) {
+            resolve({ value: v, done: d });
+        }, reject);
+    }
 };
@@ -62,5 +77,5 @@ var __asyncDelegator = undefined && undefined.__asyncDelegator || function (o) {
     function verb(n, f) {
-        if (o[n]) i[n] = function (v) {
+        i[n] = o[n] ? function (v) {
             return (p = !p) ? { value: __await(o[n](v)), done: n === "return" } : f ? f(v) : v;
-        };
+        } : f;
     }
@@ -173,12 +188,18 @@ };
                     case 0:
-                        _context2.t0 = Uint8Array;
-                        _context2.next = 3;
+                        _context2.t0 = __await;
+                        _context2.t1 = Uint8Array;
+                        _context2.next = 4;
                         return __await(arrayBuffer);
 
-                    case 3:
-                        _context2.t1 = _context2.sent;
-                        _context2.next = 6;
-                        return new _context2.t0(_context2.t1);
+                    case 4:
+                        _context2.t2 = _context2.sent;
+                        _context2.t3 = new _context2.t1(_context2.t2);
+                        _context2.next = 8;
+                        return (0, _context2.t0)(_context2.t3);
 
-                    case 6:
+                    case 8:
+                        _context2.next = 10;
+                        return _context2.sent;
+
+                    case 10:
                     case "end":
@@ -185,0 +206,0 @@ return _context2.stop();

js/push.js

@@ -19,2 +19,6 @@ "use strict";
 
+var _promise = require("babel-runtime/core-js/promise");
+
+var _promise2 = _interopRequireDefault(_promise);
+
 var _getIterator2 = require("babel-runtime/core-js/get-iterator");
@@ -46,4 +50,19 @@
     if (!_symbol2.default.asyncIterator) throw new TypeError("Symbol.asyncIterator is not defined.");
-    var m = o[_symbol2.default.asyncIterator];
-    return m ? m.call(o) : typeof __values === "function" ? __values(o) : (0, _getIterator3.default)(o);
+    var m = o[_symbol2.default.asyncIterator],
+        i;
+    return m ? m.call(o) : (o = typeof __values === "function" ? __values(o) : (0, _getIterator3.default)(o), i = {}, verb("next"), verb("throw"), verb("return"), i[_symbol2.default.asyncIterator] = function () {
+        return this;
+    }, i);
+    function verb(n) {
+        i[n] = o[n] && function (v) {
+            return new _promise2.default(function (resolve, reject) {
+                v = o[n](v), settle(resolve, reject, v.done, v.value);
+            });
+        };
+    }
+    function settle(resolve, reject, d, v) {
+        _promise2.default.resolve(v).then(function (v) {
+            resolve({ value: v, done: d });
+        }, reject);
+    }
 };
@@ -55,3 +74,3 @@
     var _ref = (0, _asyncToGenerator3.default)( /*#__PURE__*/_regenerator2.default.mark(function _callee(url, fetch, commands, objects, auth, progress) {
-        var packfile, body, response, _a, _b, parsed, e_1, _c;
+        var e_1, _a, packfile, body, response, _b, _c, parsed;
 
@@ -66,12 +85,12 @@ return _regenerator2.default.wrap(function _callee$(_context) {
                         _context.prev = 3;
-                        _a = __asyncValues((0, _parsePackResponse2.default)(response));
+                        _b = __asyncValues((0, _parsePackResponse2.default)(response));
 
                     case 5:
                         _context.next = 7;
-                        return _a.next();
+                        return _b.next();
 
                     case 7:
-                        _b = _context.sent;
+                        _c = _context.sent;
 
-                        if (_b.done) {
+                        if (_c.done) {
                             _context.next = 21;
@@ -82,3 +101,3 @@ break;
                         _context.next = 11;
-                        return _b.value;
+                        return _c.value;
 
@@ -116,3 +135,3 @@ case 11:
 
-                        if (!(_b && !_b.done && (_c = _a.return))) {
+                        if (!(_c && !_c.done && (_a = _b.return))) {
                             _context.next = 31;
@@ -123,3 +142,3 @@ break;
                         _context.next = 31;
-                        return _c.call(_a);
+                        return _a.call(_b);
 
@@ -126,0 +145,0 @@ case 31:

js/utils/asyncIteratorToBuffer.js

@@ -19,2 +19,6 @@ "use strict";
 
+var _promise = require("babel-runtime/core-js/promise");
+
+var _promise2 = _interopRequireDefault(_promise);
+
 var _getIterator2 = require("babel-runtime/core-js/get-iterator");
@@ -34,4 +38,19 @@
     if (!_symbol2.default.asyncIterator) throw new TypeError("Symbol.asyncIterator is not defined.");
-    var m = o[_symbol2.default.asyncIterator];
-    return m ? m.call(o) : typeof __values === "function" ? __values(o) : (0, _getIterator3.default)(o);
+    var m = o[_symbol2.default.asyncIterator],
+        i;
+    return m ? m.call(o) : (o = typeof __values === "function" ? __values(o) : (0, _getIterator3.default)(o), i = {}, verb("next"), verb("throw"), verb("return"), i[_symbol2.default.asyncIterator] = function () {
+        return this;
+    }, i);
+    function verb(n) {
+        i[n] = o[n] && function (v) {
+            return new _promise2.default(function (resolve, reject) {
+                v = o[n](v), settle(resolve, reject, v.done, v.value);
+            });
+        };
+    }
+    function settle(resolve, reject, d, v) {
+        _promise2.default.resolve(v).then(function (v) {
+            resolve({ value: v, done: d });
+        }, reject);
+    }
 };
@@ -43,3 +62,3 @@
     var _ref = (0, _asyncToGenerator3.default)( /*#__PURE__*/_regenerator2.default.mark(function _callee(iterator) {
-        var body, iterator_1, iterator_1_1, chunk, e_1, _a;
+        var e_1, _a, body, iterator_1, iterator_1_1, chunk;
 
@@ -46,0 +65,0 @@ return _regenerator2.default.wrap(function _callee$(_context) {

js/utils/asyncIteratorToStream.js

@@ -43,2 +43,6 @@ "use strict";
 
+var _promise = require("babel-runtime/core-js/promise");
+
+var _promise2 = _interopRequireDefault(_promise);
+
 var _getIterator2 = require("babel-runtime/core-js/get-iterator");
@@ -60,4 +64,19 @@
     if (!_symbol2.default.asyncIterator) throw new TypeError("Symbol.asyncIterator is not defined.");
-    var m = o[_symbol2.default.asyncIterator];
-    return m ? m.call(o) : typeof __values === "function" ? __values(o) : (0, _getIterator3.default)(o);
+    var m = o[_symbol2.default.asyncIterator],
+        i;
+    return m ? m.call(o) : (o = typeof __values === "function" ? __values(o) : (0, _getIterator3.default)(o), i = {}, verb("next"), verb("throw"), verb("return"), i[_symbol2.default.asyncIterator] = function () {
+        return this;
+    }, i);
+    function verb(n) {
+        i[n] = o[n] && function (v) {
+            return new _promise2.default(function (resolve, reject) {
+                v = o[n](v), settle(resolve, reject, v.done, v.value);
+            });
+        };
+    }
+    function settle(resolve, reject, d, v) {
+        _promise2.default.resolve(v).then(function (v) {
+            resolve({ value: v, done: d });
+        }, reject);
+    }
 };
@@ -73,3 +92,3 @@ function asyncIteratorToStream(iterator) {
                 return (0, _asyncToGenerator3.default)( /*#__PURE__*/_regenerator2.default.mark(function _callee() {
-                    var iterator_1, iterator_1_1, value, e_1, _a;
+                    var e_1, _a, iterator_1, iterator_1_1, value;
 
@@ -175,3 +194,3 @@ return _regenerator2.default.wrap(function _callee$(_context) {
                 var _ref = (0, _asyncToGenerator3.default)( /*#__PURE__*/_regenerator2.default.mark(function _callee2(size) {
-                    var _a, _b, value, e_2, _c;
+                    var e_2, _a, _b, _c, value;
 
@@ -183,12 +202,12 @@ return _regenerator2.default.wrap(function _callee2$(_context2) {
                                     _context2.prev = 0;
-                                    _a = __asyncValues(unbreakable(iterator));
+                                    _b = __asyncValues(unbreakable(iterator));
 
                                 case 2:
                                     _context2.next = 4;
-                                    return _a.next();
+                                    return _b.next();
 
                                 case 4:
-                                    _b = _context2.sent;
+                                    _c = _context2.sent;
 
-                                    if (_b.done) {
+                                    if (_c.done) {
                                         _context2.next = 13;
@@ -199,3 +218,3 @@ break;
                                     _context2.next = 8;
-                                    return _b.value;
+                                    return _c.value;
 
@@ -229,3 +248,3 @@ case 8:
 
-                                    if (!(_b && !_b.done && (_c = _a.return))) {
+                                    if (!(_c && !_c.done && (_a = _b.return))) {
                                         _context2.next = 23;
@@ -236,3 +255,3 @@ break;
                                     _context2.next = 23;
-                                    return _c.call(_a);
+                                    return _a.call(_b);
 
@@ -239,0 +258,0 @@ case 23:

package.json

 {
   "name": "@es-git/http-transport",
-  "version": "0.8.4",
+  "version": "0.9.0",
   "description": "",
@@ -42,4 +42,4 @@ "main": "js/index.js",
   "dependencies": {
-    "@es-git/core": "^0.8.3",
-    "@es-git/packfile": "^0.8.3"
+    "@es-git/core": "^0.9.0",
+    "@es-git/packfile": "^0.9.0"
   },
@@ -46,0 +46,0 @@ "devDependencies": {

ts/fetch.ts

@@ -1,2 +0,2 @@
-import { Ref, HasObject, Hash } from './types';
+import { Ref, Hash } from './types';
 import lsRemote, { Fetch as LsRemoteFetch } from './lsRemote';
@@ -8,3 +8,3 @@ import findDifferingRefs from './findDifferingRefs';
 import post, { Fetch as FetchPackFetch } from './post';
-import parsePackResponse, { Token } from './parsePackResponse';
+import parsePackResponse from './parsePackResponse';
 import { unpack, RawObject, Progress } from '@es-git/packfile';
@@ -132,10 +132,1 @@ import remotesToLocals from './remotesToLocals';
 
-async function* unpackWithProgress(chunks : AsyncIterableIterator<Uint8Array>, progress?: (message : string) => void){
-  let count = 0;
-  for await(const object of unpack(chunks)){
-    count++;
-    if(progress) progress(`Receiving objects: ?% (${count}/?)\r`);
-    yield object;
-  }
-  if(progress) progress(`Receiving objects: 100% (${count}/${count}), done.\n`);
-}

ts/findDifferingRefs.ts

@@ -1,2 +0,2 @@
-import { Ref, HasObject, Hash, RemoteLocalRef } from './types';
+import { Ref, HasObject, RemoteLocalRef } from './types';
 
@@ -3,0 +3,0 @@ export default async function findDifferingRefs(localRefs : Ref[], remoteRefs : RemoteLocalRef[], hasObject : HasObject){

ts/parsePackResponse.ts

@@ -1,3 +0,2 @@
-import { ClientCaps } from './types';
-import { AsyncBuffer, Buffer, decode, NEWLINE, fromHex, concat } from '@es-git/core';
+import { AsyncBuffer, decode, fromHex, concat } from '@es-git/core';
 
@@ -71,3 +70,3 @@ export interface Response {
   }),
-  'NAK ': async buffer => ({
+  'NAK ': async () => ({
     type: 'nak'
@@ -74,0 +73,0 @@ }),

ts/post.ts

@@ -1,2 +0,1 @@
-import { concat } from '@es-git/core';
 import streamToAsyncIterator from './utils/streamToAsyncIterator';
@@ -3,0 +2,0 @@ import asyncIteratorToBuffer from './utils/asyncIteratorToBuffer';

ts/push.ts

@@ -1,3 +0,2 @@
-import { decode } from '@es-git/core';
-import { pack, RawObject, Progress, HashBlob } from '@es-git/packfile';
+import { pack, Progress, HashBlob } from '@es-git/packfile';
 
@@ -4,0 +3,0 @@ import composePushRequest, { Command } from './composePushRequest';

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

397227

increased by6.28%

Number of package files

179

increased by19.33%

Lines of code

4253

increased by1.58%

Dependency changes

• + Added@es-git/core@0.9.0(transitive)

• + Added@es-git/mix@0.9.0(transitive)

• + Added@es-git/packfile@0.9.0(transitive)

• - Removed@es-git/core@0.8.3(transitive)

• - Removed@es-git/mix@0.1.2(transitive)

• - Removed@es-git/packfile@0.8.3(transitive)

• Updated@es-git/core@^0.9.0

• Updated@es-git/packfile@^0.9.0