fix: remove unecessary as casting (#140)

antondalgren · web-flow · commit d9995386b543 · 2025-05-27T13:44:42.000+02:00
diff --git a/src/amqp-channel.ts b/src/amqp-channel.ts
@@ -51,7 +51,7 @@ export class AMQPChannel {
   /**
    * Declare a queue and return an AMQPQueue instance.
    */
-  queue(name = "", {passive = false, durable = name !== "", autoDelete = name === "", exclusive = name === ""} = {} as QueueParams, args = {}): Promise<AMQPQueue> {
+  queue(name = "", { passive = false, durable = name !== "", autoDelete = name === "", exclusive = name === "" }: QueueParams = {}, args = {}): Promise<AMQPQueue> {
     return new Promise((resolve, reject) => {
       this.queueDeclare(name, {passive, durable, autoDelete, exclusive}, args)
         .then(({name}) => resolve(new AMQPQueue(this, name)))
@@ -446,7 +446,7 @@ export class AMQPChannel {
    * @param args - optional custom queue arguments
    * @return fulfilled when confirmed by the server
    */
-  queueDeclare(name = "", { passive = false, durable = name !== "", autoDelete = name === "", exclusive = name === "" } = {} as QueueParams, args = {}): Promise<QueueOk> {
+  queueDeclare(name = "", { passive = false, durable = name !== "", autoDelete = name === "", exclusive = name === "" }: QueueParams = {}, args = {}): Promise<QueueOk> {
     if (this.closed) return this.rejectClosed()
     const noWait = false
     let j = 0
@@ -591,7 +591,7 @@ export class AMQPChannel {
    * @param args - optional arguments
    * @return Fulfilled when the exchange is created or if it already exists
    */
-  exchangeDeclare(name: string, type: ExchangeType, { passive = false, durable = true, autoDelete = false, internal = false } = {} as ExchangeParams, args = {}): Promise<void> {
+  exchangeDeclare(name: string, type: ExchangeType, { passive = false, durable = true, autoDelete = false, internal = false }: ExchangeParams = {}, args = {}): Promise<void> {
     const noWait = false
     let j = 0
     const frame = new AMQPView(new ArrayBuffer(4096))
diff --git a/src/amqp-queue.ts b/src/amqp-queue.ts
@@ -63,9 +63,9 @@ export class AMQPQueue {
    * @param [params.args={}] - custom arguments
    * @param {function(AMQPMessage) : void} callback - Function to be called for each received message
    */
-  subscribe({ noAck = true, exclusive = false, tag = "", args = {} } = {} as ConsumeParams,
-            callback: (msg: AMQPMessage) => void) : Promise<AMQPConsumer> {
-    return this.channel.basicConsume(this.name, {noAck, exclusive, tag, args}, callback)
+  subscribe({ noAck = true, exclusive = false, tag = "", args = {} }: ConsumeParams = {},
+    callback: (msg: AMQPMessage) => void): Promise<AMQPConsumer> {
+    return this.channel.basicConsume(this.name, { noAck, exclusive, tag, args }, callback)
   }
 
   /**
diff --git a/src/amqp-view.ts b/src/amqp-view.ts
@@ -281,15 +281,15 @@ export class AMQPView extends DataView<Uint8Array['buffer']>  {
     switch (typeof field) {
       case "string":
         this.setUint8(i, 'S'.charCodeAt(0)); i += 1
-        i += this.setLongString(i, field as string, littleEndian)
+        i += this.setLongString(i, field, littleEndian)
         break
       case "boolean":
         this.setUint8(i, 't'.charCodeAt(0)); i += 1
         this.setUint8(i, field ? 1 : 0); i += 1
         break
       case "bigint":
         this.setUint8(i, 'l'.charCodeAt(0)); i += 1
-        this.setBigInt64(i, field as bigint, littleEndian); i += 8
+        this.setBigInt64(i, field, littleEndian); i += 8
         break
       case "number":
         if (Number.isInteger(field)) {
