INNER CODE UNIT · Java

runCommandRxJava

microshow/RxFFmpeg · rxffmpeg/src/main/java/io/microshow/rxffmpeg/RxFFmpegInvoke.java:90

    public Flowable<RxFFmpegProgress> runCommandRxJava(final String[] command) {
        return Flowable.create(new FlowableOnSubscribe<RxFFmpegProgress>() {
            @Override
            public void subscribe(final FlowableEmitter<RxFFmpegProgress> emitter) {
                setFFmpegListener(new RxFFmpegInvoke.IFFmpegListener() {
                    @Override
                    public void onFinish() {
                        emitter.onComplete();
                    }

                    @Override
                    public void onProgress(int progress, long progressTime) {
                        emitter.onNext(new RxFFmpegProgress(RxFFmpegSubscriber.STATE_PROGRESS, progress, progressTime));
                    }

                    @Override
                    public void onCancel() {
                        //设为-100 作为取消状态

View source record →