Am I using Rxjava wrong if I never have a subscriber? I want to use it to represent a pipeline of transformations from request -> response on the server side, but I don't really have side effects in this pipeline so subscribers don't really fit the model.
@a2lin yes, the point is that the subscriber receives the processed data. You would return your response to the caller by receiving it in the subscriber. In fact, nothing should be executed until you (or some operator) call subscribe. If you're okay with waiting, you can use a blocking observable to wait for data.