(objects)
| 118 | return { currentRev: 0, pushRev: 0, fetchCursor: { rev: 0, path: null } }; |
| 119 | }, |
| 120 | async pushObjects(objects) { |
| 121 | const reader = objects.getReader(); |
| 122 | try { |
| 123 | while (true) { |
| 124 | const { value, done } = await reader.read(); |
| 125 | if (done) break; |
| 126 | blobs.set(hex(value.hash), value.bytes); |
| 127 | } |
| 128 | } finally { |
| 129 | reader.releaseLock(); |
| 130 | } |
| 131 | }, |
| 132 | }; |
| 133 | } |
| 134 |