convert method

  1. @override
StreamMessage convert(
  1. GrpcMessage input
)
override

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');
}