oillio

public class MyServiceImpl extends DeviceServiceGrpc.DeviceServiceImplBase {

  @Override
  public StreamObserver<GetLocationRequest> getLocations(StreamObserver<GetLocationResponse> responseObserver) {
    RequestBridge<GetLocationRequest> request = new RequestBridge<>();
    ResponseBridge response = new ResponseBridge((ServerCallStreamObserver) responseObserver);
    request.map(this::doGetLocation)
           .subscribe(response);
    return request;
  }