File tree Expand file tree Collapse file tree 3 files changed +4
-4
lines changed
src/main/java/io/reactivex/processors Expand file tree Collapse file tree 3 files changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -58,7 +58,7 @@ public static <T> AsyncProcessor<T> create() {
58
58
* @since 2.0
59
59
*/
60
60
@ SuppressWarnings ("unchecked" )
61
- public AsyncProcessor () {
61
+ AsyncProcessor () {
62
62
this .subscribers = new AtomicReference <AsyncSubscription <T >[]>(EMPTY );
63
63
}
64
64
Original file line number Diff line number Diff line change @@ -122,7 +122,7 @@ public static <T> BehaviorProcessor<T> createDefault(T defaultValue) {
122
122
* @since 2.0
123
123
*/
124
124
@ SuppressWarnings ("unchecked" )
125
- public BehaviorProcessor () {
125
+ BehaviorProcessor () {
126
126
this .value = new AtomicReference <Object >();
127
127
this .lock = new ReentrantReadWriteLock ();
128
128
this .readLock = lock .readLock ();
@@ -136,7 +136,7 @@ public BehaviorProcessor() {
136
136
* @throws NullPointerException if {@code defaultValue} is null
137
137
* @since 2.0
138
138
*/
139
- public BehaviorProcessor (T defaultValue ) {
139
+ BehaviorProcessor (T defaultValue ) {
140
140
this ();
141
141
this .value .lazySet (ObjectHelper .requireNonNull (defaultValue , "defaultValue is null" ));
142
142
}
Original file line number Diff line number Diff line change @@ -83,7 +83,7 @@ public static <T> PublishProcessor<T> create() {
83
83
* @since 2.0
84
84
*/
85
85
@ SuppressWarnings ("unchecked" )
86
- public PublishProcessor () {
86
+ PublishProcessor () {
87
87
subscribers = new AtomicReference <PublishSubscription <T >[]>(EMPTY );
88
88
}
89
89
You can’t perform that action at this time.
0 commit comments