import { ActionBuilder, CheckBuilder, Duration, Session } from "@gatling.io/core"; import { GrpcHeaders } from "./headers"; import { GrpcInboundMessage, InitialTimestampFunction, MessageResponseTimePolicy } from "./grpc"; import JvmDescriptorsDescriptor = com.google.protobuf.Descriptors$Descriptor; import JvmGrpcServerStreamingServiceBuilder = io.gatling.javaapi.grpc.GrpcServerStreamingServiceBuilder; export interface GrpcServerStreamAwaitStreamEndActionBuilder extends ActionBuilder { } export interface GrpcServerStreamStreamSendActionBuilder extends ActionBuilder { } export interface GrpcServerStreamingServiceBuilder extends GrpcHeaders { check(...checks: CheckBuilder[]): GrpcServerStreamingServiceBuilder; deadlineAfter(duration: Duration): GrpcServerStreamingServiceBuilder; messageRequestName(messageRequestName: string): GrpcServerStreamingServiceBuilder; messageRequestName(messageRequestName: (session: Session) => string): GrpcServerStreamingServiceBuilder; messageResponseTimePolicy(messageResponseTimePolicy: MessageResponseTimePolicy): GrpcServerStreamingServiceBuilder; messageResponseTimePolicy(initialTimestampFunction: InitialTimestampFunction): GrpcServerStreamingServiceBuilder; serverConfiguration(serverConfigurationName: string): GrpcServerStreamingServiceBuilder; streamName(streamName: string): GrpcServerStreamingServiceBuilder; send(request: any): GrpcServerStreamStreamSendActionBuilder; send(request: (session: Session) => any): GrpcServerStreamStreamSendActionBuilder; processUnmatchedMessages(f: (messages: GrpcInboundMessage[], session: Session) => Session): ActionBuilder; awaitStreamEnd(): GrpcServerStreamAwaitStreamEndActionBuilder; awaitStreamEnd(reconcile: (main: Session, forked: Session) => Session): GrpcServerStreamAwaitStreamEndActionBuilder; awaitStreamEndAndProcessUnmatchedMessages(processUnmatchedMessages: (messages: GrpcInboundMessage[], session: Session) => Session): GrpcServerStreamAwaitStreamEndActionBuilder; awaitStreamEndAndProcessUnmatchedMessages(f: (messages: GrpcInboundMessage[], main: Session, forked: Session) => Session): GrpcServerStreamAwaitStreamEndActionBuilder; cancel(): ActionBuilder; } export declare const wrapGrpcServerStreamingServiceBuilder: (inputDescriptor: JvmDescriptorsDescriptor) => ((_underlying: JvmGrpcServerStreamingServiceBuilder) => GrpcServerStreamingServiceBuilder);