1

I have implemented custom web filter and trying to read complete HTTP request but getting an error on subscribing

public class AppWebFilter implements WebFilter {

@Override
    public Mono<Void> filter(ServerWebExchange exchange, WebFilterChain chain) {
        exchange.getRequest().getBody().map(m->m.read()).doOnNext(k->k.byteValue()).subscribe();
        return chain.filter(exchange);
    }
}
dkb
  • 4,389
  • 4
  • 36
  • 54

0 Answers0