apptik / rhub Goto Github PK

I try to learn from the example app.
After create a new android app by Android Studio, merge exampleapp to hear, and then fixed dependency in build.gradle
compile 'io.apptik.rhub:core:0.2.0-alpha1'
compile 'io.apptik.rhub:rxjava-v1:0.2.0-alpha1'
compile 'io.apptik.rhub:rxjava-v2:0.2.0-alpha1'
compile 'io.apptik.rhub:shield-processor-rxjava1:0.2.0-alpha1'
compile 'io.apptik.rhub:shield-base-processor:0.2.0-alpha1'
compile 'io.apptik.rhub:shield-maker-rxjava1:0.2.0-alpha1'
I faced an issue: about Unable to find implementation for interface io.apptik.rhub.exampleapp.Shield

and update img also

Subjects/Processors are currently used as multi-receivers, that is they can subscribe to multiple sources. Although this is allowed by the current implementation it is not according to the reactive streams specs. Which means implementation may change according to the specs and thus will break the behavior of RxJava2Hub

address type safety by smth like

Observable getNodeFiltered(Object tag, final Class cls)

in rxjava2 removing provider results in sending terminal event to the proxy

add internal emittability flag so emit can be standard and easier to block for specific nodes.

create shield generator that processes interface annotations. this will significantly reduce the boilerplate while having clean and safe socket to the hub.
generator should allow adding converters in the form of map and possibly flatmap