1 | import { IncomingEvent, IncomingRequest } from '../interfaces';
|
2 | import { KafkaRequest } from '../serializers/kafka-request.serializer';
|
3 | import { IncomingRequestDeserializer } from './incoming-request.deserializer';
|
4 | /**
|
5 | * @publicApi
|
6 | */
|
7 | export declare class KafkaRequestDeserializer extends IncomingRequestDeserializer {
|
8 | mapToSchema(data: KafkaRequest, options?: Record<string, any>): IncomingRequest | IncomingEvent;
|
9 | }
|