import { Observable } from 'rxjs';
import type { IpfsApi } from '@dustil/common';
import { DiagnosticsLogger, ServiceLogger } from '@dustil/common';
import { MonoTypeOperatorFunction } from 'rxjs';
import { TaskQueue } from './task-queue.js';
export declare type IPFSPubsubMessage = {
    from: string;
    seqno: Uint8Array;
    data: Uint8Array;
    topicIDs: string[];
    signature: Uint8Array;
    key: Uint8Array;
};
export declare class PubsubIncoming extends Observable<IPFSPubsubMessage> {
    readonly ipfs: IpfsApi;
    readonly topic: string;
    readonly pubsubLogger: ServiceLogger;
    readonly logger: DiagnosticsLogger;
    readonly tasks: TaskQueue;
    constructor(ipfs: IpfsApi, topic: string, pubsubLogger: ServiceLogger, logger: DiagnosticsLogger, tasks: TaskQueue);
}
export declare class IncomingChannel extends Observable<IPFSPubsubMessage> {
    readonly ipfs: IpfsApi;
    readonly topic: string;
    readonly resubscribeEvery: number;
    readonly pubsubLogger: ServiceLogger;
    readonly logger: DiagnosticsLogger;
    readonly tasks: TaskQueue;
    constructor(ipfs: IpfsApi, topic: string, resubscribeEvery: number, pubsubLogger: ServiceLogger, logger: DiagnosticsLogger, tasks?: TaskQueue);
}
export declare function filterExternal(ownPeerId$: Observable<string>): MonoTypeOperatorFunction<IPFSPubsubMessage>;
//# sourceMappingURL=incoming-channel.d.ts.map