fromSubscribePush static method

ServerSubscribedEvent fromSubscribePush(
  1. String channel,
  2. Subscribe result,
  3. bool resubscribed
)

Implementation

static ServerSubscribedEvent fromSubscribePush(String channel, proto.Subscribe result, bool resubscribed) {
  StreamPosition? streamPosition;
  if (result.positioned || result.recoverable) {
    streamPosition = StreamPosition(result.offset, result.epoch);
  }
  return ServerSubscribedEvent(
      channel, false, false, result.data, streamPosition, result.positioned, result.recoverable);
}