customerJourneyChangeEvents static method

Stream<CustomerJourneyState> customerJourneyChangeEvents()

Implementation

static Stream<CustomerJourneyState> customerJourneyChangeEvents() {
  var data = _customerJourneyChangeEvent
      .receiveBroadcastStream()
      .map((dynamic event) => _mapToCustomerJourneyState(event));

  return data;
}