subject.toFlowable will work tho
# rx
m
subject.toFlowable will work tho