convert method
Converts input
and returns the result of the conversion.
Implementation
@override
StreamMessage convert(GrpcMessage input) {
if (input is GrpcMetadata) {
final headers = <Header>[];
input.metadata.forEach((key, value) {
headers.add(Header(ascii.encode(key), utf8.encode(value)));
});
return HeadersStreamMessage(headers);
} else if (input is GrpcData) {
return DataStreamMessage(frame(input.data));
}
throw GrpcError.internal('Unexpected message type');
}