/** * Copyright 2017-2020 Plexus Interop Deutsche Bank AG * SPDX-License-Identifier: Apache-2.0 * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ import { Feature } from './GenericClientApi'; import { GenericClient } from '../../../client/generic/GenericClient'; import { ServiceDiscoveryRequest, MethodInvocationContext } from '@plexus-interop/client-api'; import { ServiceDiscoveryResponse } from '@plexus-interop/client-api'; import { StreamingInvocationClient } from './handlers/streaming/StreamingInvocationClient'; import { StreamingInvocationClientInternal } from './handlers/streaming/StreamingInvocationClientInternal'; import { InvocationClient } from './../InvocationClient'; import { ValueHandler } from './../ValueHandler'; import { Completion } from '@plexus-interop/client-api'; import { BinaryMarshallerProvider } from '@plexus-interop/io'; import { UniqueId } from '@plexus-interop/transport-common'; import { ActionReference } from '@plexus-interop/client-api'; import { Invocation } from '../../generic/Invocation'; import { MethodDiscoveryRequest } from '@plexus-interop/client-api'; import { MethodDiscoveryResponse } from '@plexus-interop/client-api'; import { GenericRequest } from '@plexus-interop/client-api'; import { InvocationObserver } from '../../generic'; import { InternalGenericClientApi } from './internal/InternalGenericClientApi'; import { InvocationHandlersRegistry } from './handlers/InvocationHandlersRegistry'; export declare class GenericClientApiImpl implements InternalGenericClientApi { protected readonly genericClient: GenericClient; protected readonly marshallerProvider: BinaryMarshallerProvider; protected readonly handlersRegistry: InvocationHandlersRegistry; private readonly log; constructor(genericClient: GenericClient, marshallerProvider: BinaryMarshallerProvider, handlersRegistry: InvocationHandlersRegistry); supported(feature: Feature): boolean; getApplicationId(): string; getApplicationInstanceId(): UniqueId; getConnectionId(): UniqueId; getMarshallerProvider(): BinaryMarshallerProvider; discoverService(discoveryRequest: ServiceDiscoveryRequest): Promise; discoverMethod(discoveryRequest: MethodDiscoveryRequest): Promise; sendRawUnaryRequest(genericRequest: GenericRequest, request: ArrayBuffer, responseHandler: ValueHandler): Promise; sendUnaryRequest(genericRequest: GenericRequest, request: any, responseHandler: ValueHandler, requestType: any, responseType: any): Promise; sendRawServerStreamingRequest(genericRequest: GenericRequest, request: ArrayBuffer, responseObserver: InvocationObserver): Promise; sendServerStreamingRequest(genericRequest: GenericRequest, request: any, responseObserver: InvocationObserver, requestType: any, responseType: any): Promise; sendRawBidirectionalStreamingRequest(request: GenericRequest, responseObserver: InvocationObserver): Promise>; sendBidirectionalStreamingRequest(genericRequest: GenericRequest, responseObserver: InvocationObserver, requestType: any, responseType: any): Promise>; sendBidirectionalStreamingRequestInternal(strInfo: string, requestInvocation: () => Promise, responseObserver: InvocationObserver): Promise>; sendServerStreamingRequestInternal(strInfo: string, requestInvocation: () => Promise, request: ArrayBuffer, responseObserver: InvocationObserver): Promise; sendUnaryRequestInternal(strInfo: string, requestInvocation: () => Promise, request: ArrayBuffer, responseHandler: ValueHandler): Promise; disconnect(completion?: Completion): Promise; invokeUnaryHandler(invocationContext: MethodInvocationContext, actionReference: ActionReference, requestPayload: any): Promise; invokeRawUnaryHandler(invocationContext: MethodInvocationContext, actionReference: ActionReference, requestPayloadBuffer: ArrayBuffer): Promise; private isDiscovered; private toInvocationHash; private requestInvocation; private createUnaryObserver; }