public class Myclass implements StreamObserver<CameraRequest>, Closeable {
  ...

  public void onNext(Request req) {
    for (Chunk chunk : getChunks(req))
      this.requestObserver.onNext(builder.setChunk(chunk).build());
  }

  ...
}