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