///
///
import { Socket } from "./native";
import { Message, MessageLike, Readable, SocketOptions, Writable } from ".";
export declare class Server extends Socket {
constructor(options?: SocketOptions);
}
interface ServerRoutingOptions {
routingId: number;
}
export interface Server extends Readable<[Message, ServerRoutingOptions]>, Writable {
}
export declare class Client extends Socket {
constructor(options?: SocketOptions);
}
export interface Client extends Readable<[Message]>, Writable {
}
export declare class Radio extends Socket {
constructor(options?: SocketOptions);
}
interface RadioGroupOptions {
group: Buffer | string;
}
export interface Radio extends Writable {
}
export declare class Dish extends Socket {
constructor(options?: SocketOptions);
join(...values: Array): void;
leave(...values: Array): void;
}
interface DishGroupOptions {
group: Buffer;
}
export interface Dish extends Readable<[Message, DishGroupOptions]> {
}
export declare class Gather extends Socket {
constructor(options?: SocketOptions);
}
export interface Gather extends Readable<[Message]> {
conflate: boolean;
}
export declare class Scatter extends Socket {
constructor(options?: SocketOptions);
}
export interface Scatter extends Writable {
conflate: boolean;
}
export declare class Datagram extends Socket {
constructor(options?: SocketOptions);
}
export interface Datagram extends Readable<[Message, Message]>, Writable<[MessageLike, MessageLike]> {
}
export {};