fromSubscribeResult static method

ServerSubscribedEvent fromSubscribeResult(
  1. String channel,
  2. SubscribeResult result
)

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