Fix NPE in JsonReaderHttpServerRequestMapper#apply

Resolves #168
Tinkoff · Jun 21, 2023 · 86587df · 86587df
1 parent 53f9ddd
commit 86587df
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/.../main/java/ru/tinkoff/kora/json/module/http/server/JsonReaderHttpServerRequestMapper.java b/.../main/java/ru/tinkoff/kora/json/module/http/server/JsonReaderHttpServerRequestMapper.java
@@ -19,7 +19,12 @@ public Mono<T> apply(HttpServerRequest request) {
  return ReactorUtils.toByteArrayMono(request.body())
  .handle((bytes, sink) -> {
  try {
- sink.next(this.reader.read(bytes));
+ var body = this.reader.read(bytes);
+ if (body != null) {
+ sink.next(body);
+ } else {
+ sink.complete();
+ }
  } catch (Exception e) {
  var httpException = HttpServerResponseException.of(e, 400, e.getMessage());
  sink.error(httpException);