File tree Expand file tree Collapse file tree 2 files changed +2
-2
lines changed
src/main/java/io/reactivex Expand file tree Collapse file tree 2 files changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -40,7 +40,7 @@ abstract class AbstractDirectTask
40
40
41
41
protected static final FutureTask <Void > DISPOSED = new FutureTask <Void >(Functions .EMPTY_RUNNABLE , null );
42
42
43
- public AbstractDirectTask (Runnable runnable ) {
43
+ AbstractDirectTask (Runnable runnable ) {
44
44
this .runnable = runnable ;
45
45
}
46
46
Original file line number Diff line number Diff line change @@ -54,7 +54,7 @@ public final class UnicastSubject<T> extends Subject<T> {
54
54
/** The optional callback when the Subject gets cancelled or terminates. */
55
55
final AtomicReference <Runnable > onTerminate ;
56
56
57
- /** deliver onNext events before error event */
57
+ /** deliver onNext events before error event. */
58
58
final boolean delayError ;
59
59
60
60
/** Indicates the single observer has cancelled. */
You can’t perform that action at this time.
0 commit comments