如何调用Observable.complete回调函数？它不能工作

import io.reactivex.Completable;
import io.reactivex.CompletableObserver;
import io.reactivex.disposables.Disposable;

public class ObservableExample {
    public static void main(String[] args) {
        Completable.fromRunnable(() -> {
            // 数据传输逻辑
            // ...
            // 数据传输完成后调用complete方法
            complete();
        }).subscribe(new CompletableObserver() {
            @Override
            public void onSubscribe(Disposable d) {
                // 可选的，可以在这里进行一些初始化操作
            }

            @Override
            public void onComplete() {
                // Observable.complete回调函数
                // 在这里执行相应的操作，比如释放资源或者进行后续处理
            }

            @Override
            public void onError(Throwable e) {
                // 可选的，处理错误情况
            }
        });
    }

    private static void complete() {
        // 调用Observable.complete方法
    }
}