|
</syntaxhighlight>
<ref name="example2">{{cite web |url=https://github.com/ballerina-platform/ballerina-distribution/blob/master/examples/worker-interaction/worker_interaction.bal |title= Worker interaction |author=Ballerina Team|date=16 September 2020 |publisher=ballerina.io}}</ref>
=== gRPC Unary Blocking ===
{{pre|1=
import ballerina/grpc;
import ballerina/log;
service HelloWorld on new grpc:Listener(9090) {
resource function hello(grpc:Caller caller, string name,
grpc:Headers headers) {
log:printInfo("Server received hello from " + name);
string message = "Hello " + name;
// Reads custom headers in request message.
string reqHeader = headers.get("client_header_key") ?: "none";
log:printInfo("Server received header value: " + reqHeader);
// Writes custom headers to response message.
grpc:Headers resHeader = new;
resHeader.setEntry("server_header_key", "Response Header value");
// Sends response message with headers.
grpc:Error? err = caller->send(message, resHeader);
if (err is grpc:Error) {
log:printError("Error from Connector: " + err.message());
}
// Sends `completed` notification to caller.
grpc:Error? result = caller->complete();
if (result is grpc:Error) {
log:printError("Error in sending completed notification to caller",
err = result);
}
}
}
}}<ref name="example3">{{cite web |url=https://github.com/ballerina-platform/ballerina-distribution/blob/master/examples/grpc-unary-blocking/grpc_unary_blocking_service.bal |title= gRPC unary blocking |author=Ballerina Team|date=16 September 2020 |publisher=ballerina.io}}</ref>
==References==
| 