import { Observable } from "rxjs";

/**
 * Type definition for microservices client options.
 */
export type MsClientOptions = {
  timeout: number;
};

/**
 * Interface defining the contract for the message bus.
 */
export interface MessageBus {
  dispatch<TResult = any, TInput = any>(
    pattern: any,
    data?: TInput,
    opts?: MsClientOptions,
  ): Promise<TResult>;

  send<TResult = any, TInput = any>(
    pattern: any,
    data?: TInput,
    opts?: MsClientOptions,
  ): Observable<TResult>;

  emit<TResult = any, TInput = any>(
    pattern: any,
    data?: TInput,
    opts?: MsClientOptions,
  ): Observable<TResult>;
}