pub type PbGetStreamResponse = GetStreamResponse;
Expand description
Alias for GetStreamResponse
.
Aliased Type§
struct PbGetStreamResponse {
pub message: Option<StreamMessage>,
pub permits: Option<Permits>,
}
Fields§
§message: Option<StreamMessage>
§permits: Option<Permits>
The number of permits acquired for this message, which should be sent back to the upstream with add_permits
.
In theory, this can also be derived from the message itself by the receiver. Here we send it explicitly to
avoid any sense of inconsistency for the derivation logic, so the receiver can simply send it back verbatim.