Skip to content

Commit a9d3a97

Browse files
committed
Format file.
1 parent 187864b commit a9d3a97

File tree

1 file changed

+41
-43
lines changed

1 file changed

+41
-43
lines changed

firebase-config/src/main/java/com/google/firebase/remoteconfig/internal/ConfigRealtimeHttpClient.java

Lines changed: 41 additions & 43 deletions
Original file line numberDiff line numberDiff line change
@@ -9,56 +9,54 @@
99
* @author Quan Pham
1010
*/
1111
public class ConfigRealtimeHttpClient {
12-
13-
private final Map<Integer, ConfigUpdateListener> listeners;
14-
private int listenerCount;
15-
16-
public ConfigRealtimeHttpClient() {
17-
listeners = new HashMap<>();
18-
listenerCount = 1;
19-
}
2012

21-
// Kicks off Http stream listening and autofetch. Will implement in later PRs
22-
private void beginRealtimeStream() {
23-
}
13+
private final Map<Integer, ConfigUpdateListener> listeners;
14+
private int listenerCount;
2415

25-
// Pauses Http stream listening
26-
private void pauseRealtimeStream() {
27-
}
28-
29-
public ConfigUpdateListenerRegistration addRealtimeConfigUpdateListener(ConfigUpdateListener configUpdateListener) {
30-
listeners.put(listenerCount, configUpdateListener);
31-
beginRealtimeStream();
32-
return new ConfigUpdateListenerRegistration(this, listenerCount++);
33-
}
34-
35-
public void removeRealtimeConfigUpdateListener(int listenerKey) {
36-
listeners.remove(listenerKey);
37-
if (listeners.isEmpty()) {
38-
pauseRealtimeStream();
39-
}
40-
}
16+
public ConfigRealtimeHttpClient() {
17+
listeners = new HashMap<>();
18+
listenerCount = 1;
19+
}
4120

42-
public static class ConfigUpdateListenerRegistration {
43-
private final ConfigRealtimeHttpClient client;
44-
private final int listenerKey;
21+
// Kicks off Http stream listening and autofetch. Will implement in later PRs
22+
private void beginRealtimeStream() {}
4523

46-
public ConfigUpdateListenerRegistration (
47-
ConfigRealtimeHttpClient client, int listenerKey) {
48-
this.client = client;
49-
this.listenerKey = listenerKey;
50-
}
24+
// Pauses Http stream listening
25+
private void pauseRealtimeStream() {}
5126

52-
public void remove() {
53-
client.removeRealtimeConfigUpdateListener(listenerKey);
54-
}
27+
public ConfigUpdateListenerRegistration addRealtimeConfigUpdateListener(
28+
ConfigUpdateListener configUpdateListener) {
29+
listeners.put(listenerCount, configUpdateListener);
30+
beginRealtimeStream();
31+
return new ConfigUpdateListenerRegistration(this, listenerCount++);
32+
}
33+
34+
public void removeRealtimeConfigUpdateListener(int listenerKey) {
35+
listeners.remove(listenerKey);
36+
if (listeners.isEmpty()) {
37+
pauseRealtimeStream();
5538
}
39+
}
40+
41+
public static class ConfigUpdateListenerRegistration {
42+
private final ConfigRealtimeHttpClient client;
43+
private final int listenerKey;
5644

57-
// Event Listener interface to be used by developers.
58-
public interface ConfigUpdateListener {
59-
// Call back for when Realtime fetches.
60-
void onEvent();
45+
public ConfigUpdateListenerRegistration(ConfigRealtimeHttpClient client, int listenerKey) {
46+
this.client = client;
47+
this.listenerKey = listenerKey;
48+
}
6149

62-
void onError(Exception error);
50+
public void remove() {
51+
client.removeRealtimeConfigUpdateListener(listenerKey);
6352
}
53+
}
54+
55+
// Event Listener interface to be used by developers.
56+
public interface ConfigUpdateListener {
57+
// Call back for when Realtime fetches.
58+
void onEvent();
59+
60+
void onError(Exception error);
61+
}
6462
}

0 commit comments

Comments
 (0)