fromSubscribeResult static method
Implementation
static ServerSubscribedEvent fromSubscribeResult(String channel, proto.SubscribeResult result) {
StreamPosition? streamPosition;
if (result.positioned || result.recoverable) {
streamPosition = StreamPosition(result.offset, result.epoch);
}
return ServerSubscribedEvent(channel, result.wasRecovering, result.recovered, result.data, streamPosition,
result.positioned, result.recoverable);
}