Loading
Sorry, something went wrong. Reload?
Sorry, we cannot display this file.
Sorry, this file is invalid so it cannot be displayed.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
<!DOCTYPE html> | |
<html lang='en'> | |
<head> | |
<meta charset='utf-8'> | |
<style> | |
body {margin: 0; padding: 10px; background-color: #ffffff} | |
h1 {margin: 5px 0 0 0; font-size: 18px; font-weight: normal; text-align: center} | |
header {margin: -24px 0 5px 0; line-height: 24px} | |
button {font: 12px sans-serif; cursor: pointer} | |
p {margin: 5px 0 5px 0} |
Loading
Sorry, something went wrong. Reload?
Sorry, we cannot display this file.
Sorry, this file is invalid so it cannot be displayed.
Loading
Sorry, something went wrong. Reload?
Sorry, we cannot display this file.
Sorry, this file is invalid so it cannot be displayed.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
final class SingleSchedulerWrapper extends Scheduler { | |
private final Scheduler delegate; | |
SingleSchedulerWrapper(Scheduler delegate) { | |
this.delegate = Objects.requireNonNull(delegate, "delegate"); | |
} | |
@Override | |
public long now(@NonNull TimeUnit unit) { |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Scheduler { | |
Default: | |
Disposable scheduleDirect(@NonNull Runnable run) | |
Disposable scheduleDirect(@NonNull Runnable run, long delay, @NonNull TimeUnit unit) // depends on Worker default-impl | |
Disposable schedulePeriodicallyDirect(@NonNull Runnable run, long initialDelay, long period, @NonNull TimeUnit unit) // uses now(TimeUnit) transitively from Worker default-impl | |
long now(@NonNull TimeUnit unit) | |
Abstract: | |
abstract Worker createWorker() | |
} |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
package io.reactivex.rxjava3.core; | |
import io.reactivex.rxjava3.annotations.NonNull; | |
import io.reactivex.rxjava3.disposables.Disposable; | |
import io.reactivex.rxjava3.plugins.RxJavaPlugins; | |
import io.reactivex.rxjava3.schedulers.Schedulers; | |
import java.util.Objects; | |
import java.util.concurrent.Executors; | |
import java.util.concurrent.TimeUnit; |
Loading
Sorry, something went wrong. Reload?
Sorry, we cannot display this file.
Sorry, this file is invalid so it cannot be displayed.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
WITHOUT DEBUG SYMBOLS DWARF | |
arguments( | |
'-H:+PreserveFramePointer', | |
'--no-server', | |
'--no-fallback', | |
'--enable-all-security-services', | |
'--report-unsupported-elements-at-runtime' | |
) |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
@Test | |
fun fuck1() { | |
val dmb = io.reactivex.schedulers.Schedulers.single() | |
val watchDog = io.reactivex.schedulers.Schedulers.from(Executors.newSingleThreadExecutor()) | |
watchDog.scheduleDirect { | |
println("watchDog scheduleDirect " + Thread.currentThread().name) | |
} |
NewerOlder