We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 5ba4afd commit a041f60Copy full SHA for a041f60
src/stream.ts
@@ -424,7 +424,7 @@ export const createHandler =
424
log("closed stream");
425
426
const localRecordValue = parsedRecordValue(localRecord?.value ?? "");
427
- if (localRecordValue != null) {
+ if (localRecordValue != null && !localRecordValue.equals(value)) {
428
try {
429
await unpin(pins, libp2pKey, localRecordValue);
430
log("unpinned %s for pinner %s", localRecordValue, libp2pKey);
@@ -436,6 +436,8 @@ export const createHandler =
436
throw e;
437
}
438
439
+ } else {
440
+ log("value unchanged, skipping unpin")
441
442
} catch (e) {
443
log.error("failed while processing stream - %e", e);
0 commit comments