gRPC service function with caller param validates incorrectly.

[daneshk]

Description:
Below is the proto definition,

syntax = "proto3";
import "google/protobuf/wrappers.proto";
 
service StreamingCalcService {
   rpc sum(stream google.protobuf.Int64Value) returns (google.protobuf.Int64Value);
   rpc incrementalSum(stream google.protobuf.Int64Value) returns (stream google.protobuf.Int64Value);
}

Below is the service implementation,

import ballerina/grpc;

listener grpc:Listener ep = new (9090);

@grpc:ServiceDescriptor {
    descriptor: ROOT_DESCRIPTOR,
    descMap: getDescriptorMap()
}
service "StreamingCalcService" on ep {
    
    remote function sum(stream<int, grpc:Error?> clientStream) returns int|error {
       int sum = 0;
       error? e = clientStream.forEach(function (int value) {
           sum += value;
       });
       return sum;
    }
    remote function incrementalSum(StreamingCalcServiceIntCaller caller, stream<int, grpc:Error?> clientStream) returns error? {
       int sum = 0;
       error? e = clientStream.forEach(function (int value) {
           sum += value;
           checkpanic caller->sendInt(sum);
       });
       check caller->complete();
    }
}

The build is failing giving the following error,

ERROR [StreamingCalcService_sample_service.bal:(18:5,25:6)] expected caller type "StreamingCalcServiceStreamintgrpcErrorCaller" but found "StreamingCalcServiceIntCaller"
error: compilation contains errors

but the correct caller is passed in service implementation.

Affected Versions:
slalpha5

[daneshk]

This is fixed in slalpha5. I tested in the wrong distribution. Now we are getting the following error

ERROR [StreamingCalcService_sample_service.bal:(18:5,25:6)] return types are not allowed with the caller

We need to allow only error? with the caller object