in this example we use buffer count which will buffer items until it will take the count number set or end of items . shall print group size :3 group size :2 concode_field_sep PlaceHolder placeHolder concode_field_sep void bufferTimeStampObservable concode_elem_sep void stringBuffer
void function ( ) { Integer [ ] loc0 = { 0 , 1 , 2 , 3 , 4 } ; Observable . from ( loc0 ) . buffer ( 3 ) . subscribe ( list -> System . out . println ( "srini_string" + list . size ( ) ) ) ; }