import type { EventHubService } from '@pikku/core/channel';
import type * as uWS from 'uWebSockets.js';
export declare class UWSEventHubService<Mappings extends Record<string, unknown> = {}> implements EventHubService<Mappings> {
    private sockets;
    constructor();
    subscribe<T extends keyof Mappings>(topic: T, channelId: string): Promise<void>;
    unsubscribe<T extends keyof Mappings>(topic: T, channelId: string): Promise<void>;
    publish<T extends keyof Mappings>(topic: T, channelId: string | null, message: Mappings[T], isBinary?: boolean): Promise<void>;
    onChannelOpened(channelId: string, socket: uWS.WebSocket<unknown>): Promise<void>;
    onChannelClosed(channelId: string): Promise<void>;
    private forwardPublishMessage;
}