...
//Server
         try {
            
            Socket socket =  new  ServerSocket(port).accept();
            
            InputStream in = socket.getInputStream();
            
            OutputStream out = socket.getOutputStream();
            
             long  iterations =  0 ;
             long  timeSum =  0 ;
            
            System.out.println("Client connected.");
                    
             while  (true) {
                
                 if  (in.available() >  0 ) {
                    
                     long  begin = System.currentTimeMillis();
                    
                     byte [] buffer =  new   byte [in.available()];
                    
                    in.read(buffer);
                    
                    System.out.print("+");
                    
                     if  (buffer[ 0 ] ==  32 ) {
                        
                         break ;
                        
                    }
                    
                    out.write(buffer);
                    
                    System.out.print("-");
                    
                     long  end = System.currentTimeMillis();
                    
                    timeSum += end - begin;
                    
                    iterations++;
                    
                }  else  {
                    
                    Thread.currentThread().sleep( 1 );
                    
                }
                
            }
            
            System.out.println("AVG time " + ( double )timeSum / iterations + " ms");
            
        }  catch  (IOException e) {
            
            e.printStackTrace();
            
        }  catch  (InterruptedException e) {
            
            e.printStackTrace();
            
        }
...
//Client
         try  {
            
            Socket socket =  new  Socket(host, port);
            
            InputStream in = socket.getInputStream();
            
            OutputStream out = socket.getOutputStream();
            
             byte [] buffer =  new   byte [ 40 ];
            
            System.out.println("Connected.");
            
             for  ( int  i =  0 ; i <  1000 ; i++) {
                
                out.write(buffer);
                
                System.out.print("+");
                
                 while  (in.available() <  39 ) {
                    
                    Thread.currentThread().sleep( 1 );
                    
                }
                
                in.read(buffer);
                
                System.out.print("-");
                
            }
            
            out.write(( byte ) 32 );
            
            System.out.println("\nDone.");
            
        }  catch  (IOException e) {
            
            e.printStackTrace();
            
        }  catch  (InterruptedException e) {
            
            e.printStackTrace();
            
        }
...