Process server stream

Initializes the server stream and returns an array of received messages

Function ProcessServerStream(Val Connection, Val Service, Val Method, Val Request, Val Timeout = 10000, Val Tls = Undefined, Val MessageCount = Undefined) Export

Parameter	CLI option	Type	Required	Description
Connection	--conn	Arbitrary	✔	Existing connection or connection parameters
Service	--service	String	✔	Service name
Method	--method	String	✔	Method name
Request	--data	Structure Of KeyAndValue	✔	First request data
Timeout	--tout	Number	✖	Timeout for individual operation (in ms))
Tls	--tls	Structure Of KeyAndValue	✖	TLS settings, if necessary. See GetTlsSettings
MessageCount	--count	Number	✖	Maximum messages to retrieve. Unlimited by default

Returns: Map Of KeyAndValue - Processing result

1C:Enterprise/OneScript code example

    Address = "https://grpcb.in:9001";

    Proto1 = "https://hut.openintegrations.dev/test_data/grpcbin_with_import.proto"; // String, path to file or URL
    Proto2 = "https://hut.openintegrations.dev/test_data/mt.proto"; // String, path to file or URL

    Scheme = New Map;
    Scheme.Insert("main.proto"    , Proto1); // Primary
    Scheme.Insert("my_types.proto", Proto2); // For import in primary

    Parameters = OPI_GRPC.GetConnectionParameters(Address, Scheme);
    Tls        = OPI_GRPC.GetTlsSettings(True);

    Service = "grpcbin.GRPCBin";
    Method  = "DummyServerStream";

    Data = New Map;
    Data.Insert("f_string" , "Test message");
    Data.Insert("f_int32"  , 123);
    Data.Insert("f_bool"   , True);
    Data.Insert("f_sub"    , New Structure("f_string", "Nested value"));

    Result = OPI_GRPC.ProcessServerStream(Parameters, Service, Method, Data, , Tls, 3);

Bash

    # JSON data can also be passed as a path to a .json file
    
    oint grpc ProcessServerStream \
     --conn "{'address':'https://grpcb.in:9001','proto':{'main.proto':'https://hut.openintegrations.dev/test_data/grpcbin_with_import.proto','my_types.proto':'https://hut.openintegrations.dev/test_data/mt.proto'}}" \
     --service "grpcbin.GRPCBin" \
     --method "DummyServerStream" \
     --data "{'f_string':'Test message','f_int32':'123','f_bool':true,'f_sub':{'f_string':'Nested value'}}" \
     --tls "{'use_tls':true,'accept_invalid_certs':true}" \
     --count 3

CMD/Bat

    :: JSON data can also be passed as a path to a .json file
    
    oint grpc ProcessServerStream ^
     --conn "{'address':'https://grpcb.in:9001','proto':{'main.proto':'https://hut.openintegrations.dev/test_data/grpcbin_with_import.proto','my_types.proto':'https://hut.openintegrations.dev/test_data/mt.proto'}}" ^
     --service "grpcbin.GRPCBin" ^
     --method "DummyServerStream" ^
     --data "{'f_string':'Test message','f_int32':'123','f_bool':true,'f_sub':{'f_string':'Nested value'}}" ^
     --tls "{'use_tls':true,'accept_invalid_certs':true}" ^
     --count 3

Result

{
 "result": true,
 "data": [
  {
   "f_bool": true,
   "f_bools": [],
   "f_bytes": {
    "BYTES": ""
   },
   "f_bytess": [],
   "f_enum": "ENUM_0",
   "f_enums": [],
   "f_float": 0,
   "f_floats": [],
   "f_int32": 123,
   "f_int32s": [],
   "f_int64": 0,
   "f_int64s": [],
   "f_string": "Test message",
   "f_strings": [],
   "f_sub": {
    "f_string": "Nested value"
   },
   "f_subs": []
  },
  {
   "f_bool": true,
   "f_bools": [],
   "f_bytes": {
    "BYTES": ""
   },
   "f_bytess": [],
   "f_enum": "ENUM_0",
   "f_enums": [],
   "f_float": 0,
   "f_floats": [],
   "f_int32": 123,
   "f_int32s": [],
   "f_int64": 0,
   "f_int64s": [],
   "f_string": "Test message",
   "f_strings": [],
   "f_sub": {
    "f_string": "Nested value"
   },
   "f_subs": []
  },
  {
   "f_bool": true,
   "f_bools": [],
   "f_bytes": {
    "BYTES": ""
   },
   "f_bytess": [],
   "f_enum": "ENUM_0",
   "f_enums": [],
   "f_float": 0,
   "f_floats": [],
   "f_int32": 123,
   "f_int32s": [],
   "f_int64": 0,
   "f_int64s": [],
   "f_string": "Test message",
   "f_strings": [],
   "f_sub": {
    "f_string": "Nested value"
   },
   "f_subs": []
  }
 ]
}