public String supplyData(){
  try {
    Thread.sleep(500);
  }
 catch (  Exception e) {
  }
  return "data";
}

public String supplyData ( ) { try { Thread . sleep ( 500 ) ; } catch ( Exception e ) { } return "data" ; }
new lazyreact ( executors . newfixedthreadpool ( 4 ) ) . of ( 6 , 5 , 2 , 1 ) . map ( this : : loaddata ) . map ( list : : size ) . peek ( e - > { system . out . println ( " data size is " + e + " on thread " + thread . currentthread ( ) . getid ( ) ) ; } ) . map ( e - > e * 100 ) . filter ( e - > e < 551 ) . foreach ( system . out : : println ) ;
