import rx.observers.Observers; //导入依赖的package包/类
public ComposeMonitor(DockerService dockerService, String fileName) {
    this.monitor = BehaviorSubject.create();
    this.dockerService = dockerService;
    this.fileName = fileName;
    this.observer = Observers.create(t -> {
        List<String> containerIds = getContainerIds();
        containerIds.forEach(s -> {
            ContainerDetails details = dockerService.getContainer(s);
            log.debug("get container {}", details);
            if (checkContainer(details)) {
                log.error("Container crashed {}", details);
                monitor.onNext(ResultCode.ERROR);
                monitor.onCompleted();
                return;
            }
        });
    });
}
 

import rx.observers.Observers; //导入依赖的package包/类
public void init() {
    init(Observers.<T>empty());
}
 

import rx.observers.Observers; //导入依赖的package包/类
public void restart() {
    restart(Observers.<T>empty());
}