Fix auto close device

stashymane · Aug 2, 2021 · 61e6a20 · 61e6a20
1 parent 33c0839
commit 61e6a20
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 3 deletions.
diff --git a/build.gradle.kts b/build.gradle.kts
@@ -9,7 +9,7 @@ plugins {
 }
 
 group = "dev.stashy.midifunk"
-version = "0.5.1"
+version = "0.5.2"
 
 repositories {
     mavenCentral()

diff --git a/src/main/kotlin/dev/stashy/midifunk/EventReceiver.kt b/src/main/kotlin/dev/stashy/midifunk/EventReceiver.kt
@@ -16,9 +16,11 @@ fun MidiDevice.to(e: MidiEvent) {
     receiver.send(e.convert(), e.timestamp)
 }
 
-class EventReceiver(dev: MidiDevice, setReceiver: Boolean = true) : Receiver {
+class EventReceiver(private val dev: MidiDevice, setReceiver: Boolean = true) :
+    Receiver {
     private var bus: PublishSubject<MidiEvent> = PublishSubject.create()
-    val observable: Observable<MidiEvent> = bus.doOnSubscribe { dev.open() }.onTerminateDetach()
+    val observable: Observable<MidiEvent>
+        get() = bus.doOnSubscribe { dev.open() }.doFinally { if (!bus.hasObservers()) dev.close() }
 
     init {
         if (setReceiver)