ratis-experiments/src/main/java/org/apache/ratis/experiments/flatbuffers/client/ClientFlat.java [105:127]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        requestObserver.onNext(msg);
        i++;
      }

    } catch (Exception e){
      System.out.println(e);
    }
    requestObserver.onCompleted();
    Thread.sleep(1000*100);
    if(recv[0] == partId){
      System.out.println("Transfer Successfull....");
    } else{
      System.out.println("Some error occurred...");
    }
  }

  public static void main(String[] args) throws Exception{
    int times = 100000;
    if(args.length != 0){
      times = Integer.parseInt(args[0]);
    }
    String target = "localhost:50051";
    ManagedChannel channel = ManagedChannelBuilder.forTarget(target).usePlaintext().build();
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



ratis-experiments/src/main/java/org/apache/ratis/experiments/flatbuffers/client/ClientProto.java [103:125]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        requestObserver.onNext(msg);
        i++;
      }

    } catch (Exception e){
      System.out.println(e);
    }
    requestObserver.onCompleted();
    Thread.sleep(1000*100);
    if(recv[0] == partId){
      System.out.println("Transfer Successfull....");
    } else{
      System.out.println("Some error occurred...");
    }
  }

  public static void main(String[] args) throws Exception{
    int times = 100000;
    if(args.length != 0){
      times = Integer.parseInt(args[0]);
    }
    String target = "localhost:50051";
    ManagedChannel channel = ManagedChannelBuilder.forTarget(target).usePlaintext().build();
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -