import { Observable } from 'rxjs';
import { MessageType } from '../constants';
import { IReplyParser } from './i-reply-parser';
import { InboundMessage, RawMessage } from '../types';
import { IInboundMessageListenerFactory } from './i-inbound-message-listener-factory';
export declare class InboundMessageListenerFactory implements IInboundMessageListenerFactory {
    create<TMessageType extends MessageType>(characteristicDataStream: Observable<RawMessage<MessageType>>, replyParserService: IReplyParser<TMessageType>, onDisconnected$: Observable<void>): Observable<InboundMessage & {
        messageType: TMessageType;
    }>;
}