public void sync ( ) { if ( getPipelinedResponseLength ( ) > 0 ) { List < Object > unformatted = client . getMany ( getPipelinedResponseLength ( ) ) ; for ( Object o : unformatted ) { generateResponse ( o ) ; } } }
Synchronize pipeline by reading all responses . This operation close the pipeline . In order to get return values from pipelined commands capture the different Response&lt ; ?&gt ; of the commands you execute .