feat: don't override array type if already exists

Bas950 · porsager · commit 62a23bb14e3f · 2023-04-05T15:48:20.000+02:00
diff --git a/cjs/src/connection.js b/cjs/src/connection.js
@@ -735,6 +735,7 @@ function Connection(options, queues = {}, { onopen = noop, onend = noop, onclose
   }
 
   function addArrayType(oid, typarray) {
+    if (!!options.parsers[typarray] && !!options.serializers[typarray]) return;
     const parser = options.parsers[oid]
     options.shared.typeArrayMap[oid] = typarray
     options.parsers[typarray] = (xs) => arrayParser(xs, parser)
diff --git a/deno/src/connection.js b/deno/src/connection.js
@@ -739,6 +739,7 @@ function Connection(options, queues = {}, { onopen = noop, onend = noop, onclose
   }
 
   function addArrayType(oid, typarray) {
+    if (!!options.parsers[typarray] && !!options.serializers[typarray]) return;
     const parser = options.parsers[oid]
     options.shared.typeArrayMap[oid] = typarray
     options.parsers[typarray] = (xs) => arrayParser(xs, parser)
diff --git a/src/connection.js b/src/connection.js
@@ -736,6 +736,7 @@ function Connection(options, queues = {}, { onopen = noop, onend = noop, onclose
   }
 
   function addArrayType(oid, typarray) {
+    if (!!options.parsers[typarray] && !!options.serializers[typarray]) return;
     const parser = options.parsers[oid]
     options.shared.typeArrayMap[oid] = typarray
     options.parsers[typarray] = (xs) => arrayParser(xs, parser)

Original file line number	Diff line number	Diff line change
`@@ -735,6 +735,7 @@ function Connection(options, queues = {}, { onopen = noop, onend = noop, onclose`
`735`	`735`	`}`
`736`	`736`
`737`	`737`	`function addArrayType(oid, typarray) {`
	`738`	`+ if (!!options.parsers[typarray] && !!options.serializers[typarray]) return;`
`738`	`739`	`const parser = options.parsers[oid]`
`739`	`740`	`options.shared.typeArrayMap[oid] = typarray`
`740`	`741`	`options.parsers[typarray] = (xs) => arrayParser(xs, parser)`
Original file line number	Diff line number	Diff line change
`@@ -739,6 +739,7 @@ function Connection(options, queues = {}, { onopen = noop, onend = noop, onclose`
`739`	`739`	`}`
`740`	`740`
`741`	`741`	`function addArrayType(oid, typarray) {`
	`742`	`+ if (!!options.parsers[typarray] && !!options.serializers[typarray]) return;`
`742`	`743`	`const parser = options.parsers[oid]`
`743`	`744`	`options.shared.typeArrayMap[oid] = typarray`
`744`	`745`	`options.parsers[typarray] = (xs) => arrayParser(xs, parser)`
Original file line number	Diff line number	Diff line change
`@@ -736,6 +736,7 @@ function Connection(options, queues = {}, { onopen = noop, onend = noop, onclose`
`736`	`736`	`}`
`737`	`737`
`738`	`738`	`function addArrayType(oid, typarray) {`
	`739`	`+ if (!!options.parsers[typarray] && !!options.serializers[typarray]) return;`
`739`	`740`	`const parser = options.parsers[oid]`
`740`	`741`	`options.shared.typeArrayMap[oid] = typarray`
`741`	`742`	`options.parsers[typarray] = (xs) => arrayParser(xs, parser)`