Added start option

rxaudiomanager/src/main/java/github/com/coneey/rxaudiomanager/mediaListener/MediaStateResolver.kt

@@ -29,6 +29,7 @@ class MediaStateResolver(private val player: MediaPlayer) : MediaPlayer.OnPrepar
     private val bufferSubject: Subject<Percent> = BehaviorSubject.create()
     private val positionSubject: Subject<Second> = BehaviorSubject.create()
     private val durationSubject: Subject<Second> = BehaviorSubject.create()
+    private var preapred = false
 
     private val infoFunction4 = Function4 { t1: MediaState, t2: Percent, t3: Second, t4: Second -> MediaInfo(t1, t2, t3, t3 / 1000, t4) }
     val infoSubject: Observable<MediaInfo> = Observable.combineLatest(
@@ -91,7 +92,9 @@ class MediaStateResolver(private val player: MediaPlayer) : MediaPlayer.OnPrepar
     }
 
     fun postWhenPrepared(runnable: MediaRunnable) {
-        onPreparedRunnables.add(runnable)
+        if (preapred) runnable.invoke(player)
+        else
+            onPreparedRunnables.add(runnable)
     }
 
     internal fun startPlayer(mp: MediaPlayer) {
@@ -134,12 +137,18 @@ class MediaStateResolver(private val player: MediaPlayer) : MediaPlayer.OnPrepar
 
     fun stop() {
         if (player.isPlaying) {
-            println("STOPPING")
             player.pause()
             positionSubject.onNext(0)
             stateSubject.onNext(MediaState.STOPPED)
         }
     }
+    fun start() {
+        if (!player.isPlaying) {
+            postWhenPrepared {
+                startPlayer(it)
+            }
+        }
+    }
 
     fun seekTo(millisecond: Millisecond) {
         if (player.isPlaying)
@@ -152,4 +161,6 @@ class MediaStateResolver(private val player: MediaPlayer) : MediaPlayer.OnPrepar
     }
 
 
+
+
 }

rxaudiomanager/src/main/java/github/com/coneey/rxaudiomanager/serviceMediaManager/PlayerService.kt

@@ -36,6 +36,7 @@ class PlayerService : LifecycleService() {
                     is ServiceCommand.Resume -> mediaManager.resume()
                     is ServiceCommand.SeekTo -> mediaManager.seekTo(it.millisecond)
                     is ServiceCommand.Restart -> mediaManager.restart()
+                    is ServiceCommand.Start -> mediaManager.start()
 
                 }
             }

rxaudiomanager/src/main/java/github/com/coneey/rxaudiomanager/serviceMediaManager/ServiceCommand.kt

@@ -9,6 +9,7 @@ sealed class ServiceCommand {
     object Resume : ServiceCommand()
     object Finish : ServiceCommand()
     object Restart : ServiceCommand()
+    object Start : ServiceCommand()
     class SeekTo(val millisecond: Millisecond) : ServiceCommand()
     class LoadStreamMusic(val url: String, val attr: AudioAttributes?) : ServiceCommand()
     class LoadResourceMusic(val resourceId: Int, val attr: AudioAttributes?) : ServiceCommand()

rxaudiomanager/src/main/java/github/com/coneey/rxaudiomanager/simpleMediaManager/InternalMediaPlayer.kt

@@ -77,7 +77,6 @@ open class InternalMediaPlayer(val player: MediaPlayer, val context: Context,
     }
 
     override fun seekTo(millisecond: Millisecond) {
-
         resolver.seekTo(millisecond)
     }
 
@@ -97,6 +96,10 @@ open class InternalMediaPlayer(val player: MediaPlayer, val context: Context,
         resolver.stop()
     }
 
+    override fun start() {
+        resolver.start()
+    }
+
     override fun finish() {
         resolver.finalize()
         mediaDisposable?.dispose()

rxaudiomanager/src/main/java/github/com/coneey/rxaudiomanager/simpleMediaManager/MediaManager.kt

@@ -14,6 +14,7 @@ interface MediaManager {
     fun seekTo(millisecond: Millisecond)
     fun finish()
     fun pause()
+    fun start()
     fun resume()
     fun stop()
     fun restart()

rxaudiomanager/src/main/java/github/com/coneey/rxaudiomanager/simpleMediaManager/MediaServiceCommandEmitter.kt

@@ -57,5 +57,9 @@ object MediaServiceCommandEmitter : MediaManager {
         commandSubject.onNext(ServiceCommand.Restart)
     }
 
+    override fun start() {
+        commandSubject.onNext(ServiceCommand.Start)
+    }
+
 
 }