@Override
      public void onError(Throwable throwable) {
        subscriber.onError(throwable);
      }
Created by rayt on 11/2/16.
Thanks Mark (@mp911de) for helping out on this example!
streaming-example/streaming-client/src/main/java/com/example/grpc/client/AverageOnSubscribe.java