/** * 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 { GenericClient } from './GenericClient'; import { Invocation } from '../../client/generic/Invocation'; import { TransportConnection } from '@plexus-interop/transport-common'; import { AnonymousSubscription } from 'rxjs/Subscription'; import { Observer } from '@plexus-interop/common'; import { ClientConnectRequest, ServiceDiscoveryRequest } from '@plexus-interop/client-api'; import { ServiceDiscoveryResponse } from '@plexus-interop/client-api'; import { UniqueId } from '@plexus-interop/protocol'; import { clientProtocol as plexus, InvocationRequestInfo } from '@plexus-interop/protocol'; import { MethodDiscoveryRequest } from '@plexus-interop/client-api'; import { MethodDiscoveryResponse } from '@plexus-interop/client-api'; import { ProvidedMethodReference } from '@plexus-interop/client-api'; export declare class GenericClientImpl implements GenericClient { private readonly clientInfo; private readonly connectionId; private readonly transportConnection; private readonly state; private log; private cancellationToken; constructor(clientInfo: ClientConnectRequest, connectionId: UniqueId, transportConnection: TransportConnection, onDisconnect?: () => Promise); getApplicationId(): string; getApplicationInstanceId(): UniqueId; getConnectionId(): UniqueId; requestInvocation(invocationInfo: InvocationRequestInfo): Promise; requestDiscoveredInvocation(methodReference: ProvidedMethodReference): Promise; acceptInvocations(observer: Observer): Promise; discoverService(discoveryRequest: ServiceDiscoveryRequest): Promise; discoverMethod(discoveryRequest: MethodDiscoveryRequest): Promise; disconnect(completion?: plexus.ICompletion): Promise; private startIncomingChannelsListener; }