// unacknowledgedTasks is a functional option that sets the value of the UnacknowledgedTasks
// field of a Subscribe call.
unacknowledgedTasks is a functional option that sets the value of the UnacknowledgedTasks
field of a Subscribe call.
// unacknowledgedTasks is a functional option that sets the value of the UnacknowledgedTasks // field of a Subscribe call .
func unacknowledgedTasks(state *internalState) executor.CallOpt {
	return func(call *executor.Call) {
		if n := len(state.unackedTasks); n > 0 {
			unackedTasks := make([]mesos.TaskInfo, 0, n)
			for k := range state.unackedTasks {
				unackedTasks = append(unackedTasks, state.unackedTasks[k])
			}
			call.Subscribe.UnacknowledgedTasks = unackedTasks
		} else {
			call.Subscribe.UnacknowledgedTasks = nil
		}
	}
}
func unacknowledgedTasks ( state * internalState ) executor . CallOpt { return func ( call * executor . Call ) { if n := len ( state . unackedTasks ) ; n > 0 { unackedTasks := make ( [ ] mesos . TaskInfo , 0 , n ) for k := range state . unackedTasks { unackedTasks = append ( unackedTasks , state . unackedTasks [ k ] ) } call . Subscribe . UnacknowledgedTasks = unackedTasks } else { call . Subscribe . UnacknowledgedTasks = nil } } }
unacknowledgedTasks is a functional option that sets the value of the UnacknowledgedTasks
field of a Subscribe call.
unacknowledgedTasks is a functional option that sets the value of the UnacknowledgedTasks field of a Subscribe call .