File tree Expand file tree Collapse file tree 2 files changed +8
-5
lines changed
main/kotlin/com/google/firebase/sessions/api
test/kotlin/com/google/firebase/sessions/api Expand file tree Collapse file tree 2 files changed +8
-5
lines changed Original file line number Diff line number Diff line change @@ -48,7 +48,10 @@ object FirebaseSessionsDependencies {
48
48
dependencies[subscriberName] = Dependency (Mutex (locked = true ))
49
49
}
50
50
51
- /* * Register and unlock the subscriber. This must be called before [getSubscribers] can return. */
51
+ /* *
52
+ * Register and unlock the subscriber. This must be called before [getRegisteredSubscribers] can
53
+ * return.
54
+ */
52
55
internal fun register (subscriber : SessionSubscriber ) {
53
56
val subscriberName = subscriber.sessionSubscriberName
54
57
val dependency = getDependency(subscriberName)
@@ -64,7 +67,7 @@ object FirebaseSessionsDependencies {
64
67
}
65
68
66
69
/* * Gets the subscribers safely, blocks until all the subscribers are registered. */
67
- internal suspend fun getSubscribers (): Map <SessionSubscriber .Name , SessionSubscriber > {
70
+ internal suspend fun getRegisteredSubscribers (): Map <SessionSubscriber .Name , SessionSubscriber > {
68
71
// The call to getSubscriber will never throw because the mutex guarantees it's been registered.
69
72
return dependencies.mapValues { (subscriberName, dependency) ->
70
73
dependency.mutex.withLock { getSubscriber(subscriberName) }
Original file line number Diff line number Diff line change @@ -104,14 +104,14 @@ class FirebaseSessionsDependenciesTest {
104
104
}
105
105
106
106
// Block until the register happens.
107
- val subscribers = FirebaseSessionsDependencies .getSubscribers ()
107
+ val subscribers = FirebaseSessionsDependencies .getRegisteredSubscribers ()
108
108
109
109
assertThat(subscribers).containsExactly(CRASHLYTICS , crashlyticsSubscriber)
110
110
}
111
111
112
112
@Test
113
113
fun getSubscribers_noDependencies () = runTest {
114
- val subscribers = FirebaseSessionsDependencies .getSubscribers ()
114
+ val subscribers = FirebaseSessionsDependencies .getRegisteredSubscribers ()
115
115
116
116
assertThat(subscribers).isEmpty()
117
117
}
@@ -121,6 +121,6 @@ class FirebaseSessionsDependenciesTest {
121
121
FirebaseSessionsDependencies .addDependency(CRASHLYTICS )
122
122
123
123
// The register never happens, wait until the timeout.
124
- withTimeout(2 .seconds) { FirebaseSessionsDependencies .getSubscribers () }
124
+ withTimeout(2 .seconds) { FirebaseSessionsDependencies .getRegisteredSubscribers () }
125
125
}
126
126
}
You can’t perform that action at this time.
0 commit comments