TestProcessorServer

new TestProcessorServer(loader: () => Promise<any>, httpEndpoints?: Record<string, string>): TestProcessorServer;

get db(): MemoryDatabase;

get store(): Store;

getConfig(request?: MessageInit<Message<"processor.ProcessConfigRequest">>, context?: HandlerContext): Promise<ProcessConfigResponse>;

processBinding(request: DataBinding, context?: HandlerContext): Promise<ProcessBindingResponse>;

processBindings(request: MessageInit<ProcessBindingsRequest>, context?: HandlerContext): Promise<ProcessBindingResponse>;

processBindingsStream(requests: AsyncIterable<ProcessStreamRequest>, context: HandlerContext): AsyncGenerator<
  | ProcessStreamResponseV3
  | {
}, void, any>;

start(request?: MessageInit<StartRequest>, context?: HandlerContext): Promise<Message<"google.protobuf.Empty">>;

stop(request?: Message, context?: HandlerContext): Message<"google.protobuf.Empty">;