File tree Expand file tree Collapse file tree 1 file changed +5
-2
lines changed
src/main/java/rx/internal/util Expand file tree Collapse file tree 1 file changed +5
-2
lines changed Original file line number Diff line number Diff line change @@ -241,8 +241,9 @@ public class RxRingBuffer implements Subscription {
241
241
* r.o.OperatorObserveOnPerf.observeOnNewThread 1000000 thrpt 5 1.173 0.100 ops/s
242
242
* } </pre>
243
243
*/
244
- static int defaultSize = 128 ;
245
244
static {
245
+ int defaultSize = 128 ;
246
+
246
247
// lower default for Android (https://github.com/ReactiveX/RxJava/issues/1820)
247
248
if (PlatformDependent .isAndroid ()) {
248
249
defaultSize = 16 ;
@@ -257,8 +258,10 @@ public class RxRingBuffer implements Subscription {
257
258
System .err .println ("Failed to set 'rx.buffer.size' with value " + sizeFromProperty + " => " + e .getMessage ()); // NOPMD
258
259
}
259
260
}
261
+
262
+ SIZE = defaultSize ;
260
263
}
261
- public static final int SIZE = defaultSize ;
264
+ public static final int SIZE ;
262
265
263
266
/* Public so Schedulers can manage the lifecycle of the inner worker. */
264
267
public static final ObjectPool <Queue <Object >> SPSC_POOL = new ObjectPool <Queue <Object >>() {
You can’t perform that action at this time.
0 commit comments