• RxJs wrapper around grpc.invoke that creates an Observable. On subscription, the underlying grpc.invoke is called. On unsubscription, the active request is closed.

    Type Parameters

    • Req extends ProtobufMessage

    • Res extends ProtobufMessage

    Parameters

    • methodDescriptor: MethodDefinition<Req, Res>
    • options: RpcOptions<Req, Res>

    Returns Observable<GrpcInvoke<Res>>