fix: pos update roll back when seeking

befovy · May 16, 2020 · 064f062 · 064f062
1 parent 9759227
commit 064f062
Show file tree

Hide file tree

Showing 3 changed files with 25 additions and 3 deletions.
diff --git a/android/src/main/java/com/befovy/fijkplayer/FijkPlayer.java b/android/src/main/java/com/befovy/fijkplayer/FijkPlayer.java
@@ -276,6 +276,12 @@ private void handleEvent(int what, int arg1, int arg2, Object extra) {
                 mWidth = arg1;
                 mHeight = arg2;
                 break;
+            case SEEK_COMPLETE:
+                event.put("event", "seek_complete");
+                event.put("pos", arg1);
+                event.put("err", arg2);
+                mEventSink.success(event);
+                break;
             case ERROR:
                 mEventSink.error(String.valueOf(arg1), extra.toString(), arg2);
                 break;
@@ -311,6 +317,7 @@ public void onEvent(IjkMediaPlayer ijkMediaPlayer, int what, int arg1, int arg2,
             case AUDIO_RENDERING_START:
             case CURRENT_POSITION_UPDATE:
             case VIDEO_ROTATION_CHANGED:
+            case SEEK_COMPLETE:
                 handleEvent(what, arg1, arg2, extra);
                 break;
             default:

diff --git a/ios/Classes/FijkPlayer.m b/ios/Classes/FijkPlayer.m
@@ -366,6 +366,13 @@ - (void)handleEvent:(int)what
         _width = arg1;
         _height = arg2;
         break;
+    case 600:
+        [_eventSink success:@{
+            @"event" : @"seek_complete",
+            @"pos" : @(arg1),
+            @"err" : @(arg2),
+        }];
+        break;
     case IJKMPET_ERROR:
         [_eventSink error:[NSString stringWithFormat:@"%d", arg1]
                   message:extra ? [NSString stringWithUTF8String:extra] : nil
@@ -391,7 +398,8 @@ - (void)onEvent4Player:(IJKFFMediaPlayer *)player
     case IJKMPET_VIDEO_RENDERING_START:
     case IJKMPET_AUDIO_RENDERING_START:
     case IJKMPET_ERROR:
-    case 510:
+    case IJKMPET_CURRENT_POSITION_UPDATE:
+    case 600:
     case IJKMPET_VIDEO_ROTATION_CHANGED:
         [self handleEvent:what andArg1:arg1 andArg2:arg2 andExtra:extra];
         break;
@@ -554,12 +562,12 @@ - (void)handleMethodCall:(FlutterMethodCall *)call
         result(nil);
     } else if ([@"seekTo" isEqualToString:call.method]) {
         long pos = [argsMap[@"msec"] longValue];
-        [_ijkMediaPlayer seekTo:pos];
         if (_state == completed)
             [self handleEvent:IJKMPET_PLAYBACK_STATE_CHANGED
                       andArg1:paused
                       andArg2:-1
                      andExtra:nil];
+        [_ijkMediaPlayer seekTo:pos];
         result(nil);
     } else if ([@"setLoop" isEqualToString:call.method]) {
         int loopCount = [argsMap[@"loop"] intValue];

diff --git a/lib/core/fijkplayer.dart b/lib/core/fijkplayer.dart
@@ -99,6 +99,7 @@ class FijkPlayer extends ChangeNotifier implements ValueListenable<FijkValue> {
   Stream<Duration> get onCurrentPosUpdate => _currentPosController.stream;
 
   bool _buffering = false;
+  bool _seeking = false;
 
   /// return true if the player is buffering
   bool get isBuffering => _buffering;
@@ -430,6 +431,7 @@ class FijkPlayer extends ChangeNotifier implements ValueListenable<FijkValue> {
       return Future.error(StateError("Non playable state $state"));
     } else {
       FijkLog.i("$this invoke seekTo msec:$msec");
+      _seeking = true;
       _channel.invokeMethod("seekTo", <String, dynamic>{"msec": msec});
     }
   }
@@ -550,7 +552,9 @@ class FijkPlayer extends ChangeNotifier implements ValueListenable<FijkValue> {
       case 'pos':
         int pos = map['pos'];
         _currentPos = Duration(milliseconds: pos);
-        _currentPosController.add(_currentPos);
+        if (!_seeking) {
+          _currentPosController.add(_currentPos);
+        }
         break;
       case 'size_changed':
         int width = map['width'];
@@ -559,6 +563,9 @@ class FijkPlayer extends ChangeNotifier implements ValueListenable<FijkValue> {
         _setValue(
             value.copyWith(size: Size(width.toDouble(), height.toDouble())));
         break;
+      case 'seek_complete':
+        _seeking = false;
+        break;
       default:
         break;
     }