kalpeshp0310

public static Action1<Throwable> crashOnError() {
    final Throwable checkpoint = new Throwable();
    return throwable -> {
        StackTraceElement[] stackTrace = checkpoint.getStackTrace();
        StackTraceElement element = stackTrace[1]; // First element after `crashOnError()`
        String msg = String.format("onError() crash from subscribe() in %s.%s(%s:%s)",
            element.getClassName(),
            element.getMethodName(),
            element.getFileName(),
            element.getLineNumber());

kalpeshp0310

public class NetworkHelper {
  private OkHttpClient okHttpClient;
  private Gson gson;
  
  public NetworkHelper(OkHttpClient okHttpClient, Gson gson) {
    this.okHttpClient = okHttpClient;
    this.gson = gson;
  }
  
  /**

kalpeshp0310

package main

import (
	"context"
	"flag"
	"fmt"
	"log"
	"net/http"
	"os"
	"os/signal"