INNER CODE UNIT · Java

subscribe

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

            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 作为取消状态
                        emitter.onNext(new RxFFmpegProgress(RxFFmpegSubscriber.STATE_CANCEL));
                    }

View source record →