private Completable initFromBeginningToNow() {
    return initWithCallback(new Action1<PartitionAndSeqno>() {
      @Override
      public void call(PartitionAndSeqno partitionAndSeqno) {
        short partition = partitionAndSeqno.partition();
        long seqno = partitionAndSeqno.seqno();
        PartitionState partitionState = sessionState().get(partition);
        partitionState.setEndSeqno(seqno);
        sessionState().set(partition, partitionState);
      }
    });
  }
private Completable initFromBeginningToNow ( ) { return initWithCallback ( new Action1 < PartitionAndSeqno > ( ) { @ Override public void call ( PartitionAndSeqno partitionAndSeqno ) { short partition = partitionAndSeqno . partition ( ) ; long seqno = partitionAndSeqno . seqno ( ) ; PartitionState partitionState = sessionState ( ) . get ( partition ) ; partitionState . setEndSeqno ( seqno ) ; sessionState ( ) . set ( partition , partitionState ) ; } } ) ; }
Initializes the session state from beginning to now.