@Remoter
public interface ISampleService {
     //Returns a RemoteObservable<String> 
     RemoteObservable<String> getRemoteObservable();
}

@Override
public RemoteObservable<Integer> getDownloadObservable() {
	//Use the factory tied to "Download"	
	return RemoteObservables.<Integer>of("Download").newObservable();
}	
   ...
   	...
        	
//send the events
RemoteObservables.<Integer>of("Download").onNext(50);
RemoteObservables.<Integer>of("Download").onNext(100);

...
//complete
RemoteObservables.<Integer>of("Download").onCompleted();

 			
@Override
public RemoteObservable<String> getRemoteObservable() {
	//wrap your observable with a RemoteObservable to return across Binder
	return new RemoteObservable<>(Observable.from(new String[]{"Hello", "World"}););
}	

ISampleService sampleService = new ISampleService_Proxy( binder ); //See remoter
Observable<String> observable = sampleService.getRemoteObservable().getObservable();

//This is an Rx Java observable that can be subsribed to get data from your remote service

ISampleService sampleService = new ISampleService_Proxy( binder ); //See remoter
RemoteObservable<String> remoteData = sampleService.getRemoteObservable();

//get last data
String data = remoteData.getData();

//listen for updates
remoteData.setDataListener(data -> {});