Pipeline channel problem

Hello everyone.

I have a problem with channel pipeline in Android. The Repository has a producer like the code below:

The scan function sends Devices whenever the ChannelScanCallback is called. The presenter is here:

Even the repository produces several items, the presenter consume nothing.

Can anyone help me? Thanks in advance.