blob: 8c336e07bb0ded96e842b76d1945c67b5986af21 [file] [log] [blame]
// Copyright (C) 2019 The Android Open Source Project
//
// 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 {ConsumerPortResponse} from './consumer_port_types';
export type ConsumerPortCallback = (_: ConsumerPortResponse) => void;
export type ErrorCallback = (_: string) => void;
export type StatusCallback = (_: string) => void;
export abstract class RpcConsumerPort {
// The responses of the call invocations should be sent through this listener.
// This is done by the 3 "send" methods in this abstract class.
private consumerPortListener: Consumer;
constructor(consumerPortListener: Consumer) {
this.consumerPortListener = consumerPortListener;
}
// RequestData is the proto representing the arguments of the function call.
abstract handleCommand(methodName: string, requestData: Uint8Array): void;
sendMessage(data: ConsumerPortResponse) {
this.consumerPortListener.onConsumerPortResponse(data);
}
sendErrorMessage(message: string) {
this.consumerPortListener.onError(message);
}
sendStatus(status: string) {
this.consumerPortListener.onStatus(status);
}
}
export interface Consumer {
onConsumerPortResponse(data: ConsumerPortResponse): void;
onError: ErrorCallback;
onStatus: StatusCallback;
}