У меня запущена служба, которая сканирует устройства BLE. Эта служба, которую я читаю для конкретного устройства, зная MAC-адрес, теперь возникает, когда я читаю кадры, а также те кадры, которые устройство передает в потоковом режиме. чтобы запустить какой-то процесс в течение нескольких минут, и когда устройство отправляет другой поток, говоря, что этот процесс больше не нужен, я должен выключить его.
Я использую RxJava, но я довольно новичок в этом, так чтоУ меня есть наблюдаемое, которое выполняет этот процесс, поэтому всякий раз, когда я включаю процесс, я хочу подписаться на процесс и начать его выполнение, а когда получаю сигнал на его отключение, отписываюсь от Observable.
myвопрос заключается в том, что мне приходится многократно запускать этот процесс, могу ли я подписаться и отписаться от этой наблюдаемой более одного раза?