@bunt/queue - npm Package Compare versions

Comparing version 0.24.40 to 0.24.45

dist/interfaces.d.ts

@@ -5,5 +5,5 @@ import { Context, IDisposable } from "@bunt/unit";
 import { Incoming, IQueueList, IQueueReader, Message, MessageCtor, MessageHandler, MessagePayload, TaskAbstract } from "./Queue";
-export declare type ActionHandler<C extends Context, M extends Message> = Handler<C, M>;
-export declare type HandlerReturn<M extends Message> = M extends TaskAbstract<any, infer R> ? Promisify<R> : Promisify<void>;
-export declare type HandlerState<M extends Message> = {
+export type ActionHandler<C extends Context, M extends Message> = Handler<C, M>;
+export type HandlerReturn<M extends Message> = M extends TaskAbstract<any, infer R> ? Promisify<R> : Promisify<void>;
+export type HandlerState<M extends Message> = {
     payload: MessagePayload<M>;
@@ -10,0 +10,0 @@ };

dist/PubSub/interfaces.d.ts

 import { ITransport } from "../interfaces";
 import { SubscriptionManager } from ".";
 export declare const SubscriptionListenerId: unique symbol;
-export declare type PubSubChannel<K extends string | symbol | number = string> = Extract<K, string> | [channel: Extract<K, string>, ...channelSubKeys: (string | number)[]];
-export declare type SubscriptionManagerListener = (message: string) => unknown;
-export declare type SubscriptionId = {
+export type PubSubChannel<K extends string | symbol | number = string> = Extract<K, string> | [channel: Extract<K, string>, ...channelSubKeys: (string | number)[]];
+export type SubscriptionManagerListener = (message: string) => unknown;
+export type SubscriptionId = {
     channel: string;
@@ -8,0 +8,0 @@ [SubscriptionListenerId]: SubscriptionManagerListener;

dist/PubSub/SubscriptionManager.d.ts

@@ -5,3 +5,3 @@ import { IDisposable } from "@bunt/unit";
 import { SubscriptionList } from "./SubscriptionList";
-export declare type SubscriptionManagerConfig = [list: SubscriptionList, state: Defer<void>];
+export type SubscriptionManagerConfig = [list: SubscriptionList, state: Defer<void>];
 export declare abstract class SubscriptionManager implements IDisposable {
@@ -8,0 +8,0 @@ #private;

dist/Queue/interfaces.d.ts

@@ -19,3 +19,3 @@ import { IDisposable } from "@bunt/unit";
 }
-export declare type OperationReleaseState<M extends Message> = IReadOperationSuccess<M> | IReadOperationFail<M>;
+export type OperationReleaseState<M extends Message> = IReadOperationSuccess<M> | IReadOperationFail<M>;
 export interface IReadOperation<M extends Message> {
@@ -35,4 +35,4 @@ readonly message: M;
 }
-export declare type MessageHandler<M extends Incoming> = (message: M) => M extends TaskAbstract<any, any> ? Promisify<TaskReply<M>> : Promisify<any>;
-export declare type QueueKeys<T> = Extract<keyof T, string>;
+export type MessageHandler<M extends Incoming> = (message: M) => M extends TaskAbstract<any, any> ? Promisify<TaskReply<M>> : Promisify<any>;
+export type QueueKeys<T> = Extract<keyof T, string>;
 export interface IHandleReleaseFactory<M extends Message> {
@@ -51,4 +51,4 @@ (): IReadOperationSuccess<M>;
 }
-export declare type MessagePayload<M extends Message> = M extends MessageAbstract<infer P> ? P : never;
-export declare type TaskReply<M extends Task> = M extends TaskAbstract<any, infer P> ? P : never;
+export type MessagePayload<M extends Message> = M extends MessageAbstract<infer P> ? P : never;
+export type TaskReply<M extends Task> = M extends TaskAbstract<any, infer P> ? P : never;
 export interface MessageCtor<M extends Incoming> {
@@ -64,5 +64,5 @@ prototype: M;
 }
-export declare type Task = TaskAbstract<any, any>;
-export declare type Message = MessageAbstract<any>;
-export declare type Incoming = Task | Message;
+export type Task = TaskAbstract<any, any>;
+export type Message = MessageAbstract<any>;
+export type Incoming = Task | Message;
 export interface IMessageSerializer {
@@ -69,0 +69,0 @@ serialize(): string;

package.json

 {
     "name": "@bunt/queue",
-    "version": "0.24.40",
+    "version": "0.24.45",
     "keywords": [
@@ -29,3 +29,3 @@ "typescript"
     "dependencies": {
-        "@bunt/unit": "^0.24.40",
+        "@bunt/unit": "^0.24.45",
         "@bunt/util": "^0.24.38",
@@ -35,3 +35,3 @@ "ioredis": "^5.2.4"
     "license": "MIT",
-    "gitHead": "914f04f6a85b23bce91453de66413e2f51bba450"
+    "gitHead": "e15ed9b7a07c91e46ca69d511e9c71d8be7a0696"
 }

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

Worsened metrics

Total package byte prevSize

128812

decreased by-0.09%

Dependency changes

• Updated@bunt/unit@^0.24.45