/// <reference types="node" />
import { RSocketConnector } from 'rsocket-core';
import { Codec } from 'rsocket-messaging';
import { Operation, OperationList } from '../src/wasmrs';
export declare function newConnector(file: string): Promise<[RSocketConnector, OperationList]>;
export declare function newWorker(file: string): Promise<[RSocketConnector, OperationList]>;
export declare class MessagePackCodec implements Codec<unknown> {
    readonly mimeType: string;
    decode(buffer: Buffer): unknown;
    encode(entity: string): Buffer;
}
export declare const MESSAGEPACK_CODEC: MessagePackCodec;
export declare class JsonCodec implements Codec<unknown> {
    readonly mimeType: string;
    decode(buffer: Buffer): unknown;
    encode(entity: string): Buffer;
}
export declare const JSON_CODEC: JsonCodec;
export declare function testStream(op: Operation, connector: RSocketConnector): Promise<null>;
export declare function testRequest(op: Operation, connector: RSocketConnector): Promise<null>;