feat: support asynchronous subscriptions

packages/@wroud/flow-middleware/CHANGELOG.md

@@ -27,10 +27,6 @@ All notable changes to this project will be documented in this file.
 ## 0.2.0 (2024-11-26)
 
 <!-- changelog -->
-### ✨ Features
-
-- base implementation ([74bb7e2](https://github.com/Wroud/foundation/commit/74bb7e2))
-
 ### 🩹 Fixes
 
 - do not copy data object ([02ce20a](https://github.com/Wroud/foundation/commit/02ce20a))

packages/@wroud/flow-middleware/src/FlowMiddleware.ts

@@ -5,10 +5,6 @@ import { MiddlewareRequest } from "./MiddlewareRequest.js";
 import type { IErrorMiddleware } from "./interfaces/IErrorMiddleware.js";
 import type { ILogger } from "@wroud/api-logger";
 
-/**
- * Singleton class to register and manage middlewares.
- * @template Data - The shape of the request data.
- */
 export class FlowMiddleware<Data = Record<string, any>>
   implements IFlowMiddleware<Data>
 {
@@ -20,29 +16,16 @@ export class FlowMiddleware<Data = Record<string, any>>
     this.errorMiddlewares = [];
   }
 
-  /**
-   * Registers a middleware globally.
-   * @param {Middleware<Data>} middleware - The middleware function to register.
-   */
   public use(...middleware: IMiddleware<Data>[]): this {
     this.middlewares.push(...middleware);
     return this;
   }
 
-  /**
-   * Registers an error-handling middleware globally.
-   * @param {ErrorMiddleware<Data>} errorMiddleware - The error middleware function to register.
-   */
   public error(...errorMiddleware: IErrorMiddleware<Data>[]): this {
     this.errorMiddlewares.push(...errorMiddleware);
     return this;
   }
 
-  /**
-   * Creates a new MiddlewareRequest instance.
-   * @param {Data} initialData - Initial data for the request.
-   * @returns {MiddlewareRequest<Data>} A new MiddlewareRequest instance.
-   */
   public createRequest(
     initialData: Data = {} as Data,
   ): IMiddlewareRequest<Data> {