Блог

Я новичок в RxKotlin/RxJava. Я разрабатываю фоновый сервис в Android.

На моей службе у меня есть

• Разъем Bluetooth
• TCP-сокет

Всякий раз, когда данные доступны в сокете Bluetooth, считывайте и записывайте их в сокет TCP. И всякий раз, когда данные поступают в TCP-сокет, записывайте их в разъем Bluetooth.

Кто-нибудь может мне помочь:

• как добиться этого с помощью наблюдаемых объектов?
• как обмениваться информацией об идентификаторе сокета?
• как обмениваться данными? Спасибо

Пожалуйста, попробуйте использовать RxSubjects (https://blog.mindorks.com/understanding-rxjava-subject-publish-replay-behavior-and-async-subject-224d663d452f)

Позвольте мне привести здесь в качестве примера объект публикации.

 //a publish subject which publishes int values
public PublishSubject<Integer> source = PublishSubject.create();
source.onNext(1);
source.onNext(2);
 

Таким образом, приведенные выше строки кода относятся к классу сокетов Bluetooth.

Теперь в классе сокетов TCP, используя исходный код, вы можете наблюдать здесь.

 source
    .subscribe(
        {
           //result
        },
        {
           //error
        }
    )
 

Вот и все.

Пожалуйста, убедитесь, что подписка происходит до того, как гнездо Bluetooth начнет публиковать данные.