/tripkit/TripKitData/com.skedgo.tripkit.data.locations/LocationsFetchCoordinator/shareInFlight

shareInFlight

\ fun shareInFlight(key: String, block: () -> Observable<List<LocationsResponse.Group>>): Observable<List<LocationsResponse.Group>>

Runs block under an in-flight guard keyed by key. If another subscriber is already waiting on the same key, they share the same underlying network call.

The shared observable is removed from the map on terminate so the next request after completion re-evaluates cache freshness instead of replaying a stale result.