break drain
				}
			}
		}
	}()

	lastBatchProcess := time.Now()

	buf := bytebufferpool.Get()
	enc := jsoniter.ConfigCompatibleWithStandardLibrary.NewEncoder(buf)
	defer bytebufferpool.Put(buf)

	isDirQueue := h.config.QueueDir != ""

	// globalBuffer is always created or adjusted
	// before this method is launched.
	logChLock.Lock()
	globalBuffer := logChBuffers[name]
	logChLock.Unlock()

        checkArgument(!map.containsKey(key), "Duplicate key [%s] found.", key);

        checkArgument(entryFields.hasNext(), INVALID_ENTRY_MESSAGE, entry);
        String value = entryFields.next();
        map.put(key, value);

        checkArgument(!entryFields.hasNext(), INVALID_ENTRY_MESSAGE, entry);
      }
      return Collections.unmodifiableMap(map);
    }
  }

  private interface Strategy {

            } else {
                curResp.setExpiration(null);
            }

            curResp.setMid(k);
            this.response_map.put(k, curResp);

            final Request next = curReq.getNext();
            if (next == null) {
                break;
            }
            curReq = next;
            curResp = next.getResponse();

            for (final Map<String, Object> doc : results) {
                final String docId = (String) doc.get("doc_id");
                if (docId != null) {
                    resultMap.put(docId, doc);
                }
            }
            final List<Map<String, Object>> orderedResults = new ArrayList<>();
            for (final String docId : docIds) {

                    synchronized (this) {
                        response.received = false;
                        resp.isReceived = false;
                        try {
                            response_map.put(req, resp);

                            /*
                             * Send multiple fragments
                             */

                            do {
                                doSend0(req);

그런 경우에는 반환 타입 대신 *경로 처리 데코레이터*의 매개변수 `response_model`을 사용할 수 있습니다.

`response_model` 매개변수는 모든 *경로 처리*에서 사용할 수 있습니다:

* `@app.get()`
* `@app.post()`
* `@app.put()`
* `@app.delete()`
* 등.

{* ../../docs_src/response_model/tutorial001_py310.py hl[17,22,24:27] *}

/// note | 참고

`response_model`은 "데코레이터" 메서드(`get`, `post` 등)의 매개변수입니다. 모든 매개변수와 body처럼, *경로 처리 함수*의 매개변수가 아닙니다.

                if (StringUtil.isBlank(docId) || deleteFileMap.containsKey(docId)) {
                    deleteFile(path);
                } else {
                    deleteFileMap.put(docId, path);
                }
            }
            deletedFileList.clear();

            if (!deleteFileMap.isEmpty()) {
                final String docIdField = fessConfig.getIndexFieldDocId();

    // which had real keys with null values.)
    Map<String, String> removalNotifications = new HashMap<>();
    for (RemovalNotification<String, String> notification : listener) {
      removalNotifications.put(notification.getKey(), notification.getValue());
      assertWithMessage("Unexpected key/value pair passed to removalListener")
          .that(notification.getValue())
          .isEqualTo(notification.getKey());
    }

    // which had real keys with null values.)
    Map<String, String> removalNotifications = new HashMap<>();
    for (RemovalNotification<String, String> notification : listener) {
      removalNotifications.put(notification.getKey(), notification.getValue());
      assertWithMessage("Unexpected key/value pair passed to removalListener")
          .that(notification.getValue())
          .isEqualTo(notification.getKey());
    }

            if (servers != null) {
                for (Server server : servers) {
                    if (!serversById.containsKey(server.getId())) {
                        serversById.put(server.getId(), server);
                    }
                }
            }

            for (ArtifactRepository repository : repositories) {
                Server server = serversById.get(repository.getId());