• Calls fromGrpcSource and adds some resource specific handling for stream control messages that do not contain data, but are sent as data messages. This implements the special handleing for the INITIAL_SYNC_COMPLETE message.

    Type Parameters

    • Req extends ProtobufMessage

    • Res extends ProtobufMessage

    Parameters

    • methodDescriptor: MethodDefinition<Req, Res>

      The GRPC service method definition to be queried.

    • options: ResourceRpcOptions<Req, Res>

      Options to pass to the GRPC call.

    Returns Observable<GrpcSource<Res>>