from static method

SubscribedEvent from(
  1. SubscribeResult result
)

Implementation

static SubscribedEvent from(proto.SubscribeResult result) {
  StreamPosition? streamPosition;
  if (result.positioned || result.recoverable) {
    streamPosition = StreamPosition(result.offset, result.epoch);
  }
  return SubscribedEvent(result.wasRecovering, result.recovered, result.data, streamPosition,
      result.positioned, result.recoverable);
}