usesStreamEnvelope reports whether the transport needs a typed stream envelope to carry both the one-shot method payload and streaming payload items.
(e *expr.GRPCEndpointExpr)
| 1350 | // envelope to carry both the one-shot method payload and streaming payload |
| 1351 | // items. |
| 1352 | func usesStreamEnvelope(e *expr.GRPCEndpointExpr) bool { |
| 1353 | return e.MethodExpr.IsPayloadStreaming() && !isEmpty(e.Request.Type) |
| 1354 | } |
| 1355 | |
| 1356 | // makeProtoBufStreamEnvelope builds the protobuf stream envelope that carries |
| 1357 | // the initial request payload frame and subsequent stream item frames. |
no test coverage detected