mirror of
https://github.com/nestjs/nest.git
synced 2026-02-21 23:11:44 +00:00
18 lines
400 B
TypeScript
18 lines
400 B
TypeScript
import { Observable } from 'rxjs';
|
|
|
|
/**
|
|
* @publicApi
|
|
*/
|
|
export interface MessageHandler<TInput = any, TContext = any, TResult = any> {
|
|
(
|
|
data: TInput,
|
|
ctx?: TContext,
|
|
): Promise<Observable<TResult>> | Promise<TResult>;
|
|
next?: (
|
|
data: TInput,
|
|
ctx?: TContext,
|
|
) => Promise<Observable<TResult>> | Promise<TResult>;
|
|
isEventHandler?: boolean;
|
|
extras?: Record<string, any>;
|
|
}
|