public void handleRequest()

in playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/EgressWebServer.java [64:83]

• 16 lines of code
• 3 McCabe index (conditional complexity)

    public void handleRequest(HttpServerExchange exchange) {
      final String topic = exchange.getRelativePath().substring(1);

      final BlockingQueue<ByteString> queue = queues.get(topic);

      if (queue != null) {
        final ByteString message = queue.poll();

        if (message != null) {
          exchange.getResponseHeaders().put(Headers.STATUS, StatusCodes.OK);
          exchange.getResponseSender().send(message.asReadOnlyByteBuffer());
        } else {
          exchange.getResponseHeaders().put(Headers.STATUS, StatusCodes.NOT_FOUND);
        }
      } else {
        exchange.getResponseHeaders().put(Headers.STATUS, StatusCodes.METHOD_NOT_ALLOWED);
      }

      exchange.endExchange();
    }