resend_state.go

package quickfix

type resendState struct {
	inSession
}

func (state resendState) FixMsgIn(session *Session, msg Message) (nextState sessionState) {
	for ok := true; ok; {
		nextState = state.inSession.FixMsgIn(session, msg)

		switch nextState.(type) {
		case logoutState, latentState, resendState:
			return
		}

		msg, ok = session.messageStash[session.store.NextTargetMsgSeqNum()]
	}

	if len(session.messageStash) != 0 {
		nextState = resendState{}
	}

	return
}