Concurrent method call should be serialized

[fritzprix]

Concurrent method call should be serialized

[fritzprix]

[fritzprix]

Request method in BaseServiceProxy

        return Observable.just(endpoint.toRequest(args))
                .doOnNext(request -> request.setNonce(++requestNonce))
                .doOnNext(this::registerSession)
                .doOnNext(request -> Log.debug("request => {}", request))
                .map(request -> {
                    requestWaitQueue.put(request.getNonce(), request);
                    converter.write(request, writer);
                    synchronized (request) {
                        request.wait();
                    }
                    return request.getResponse();
                })
                .doOnError(this::onError)
                .subscribeOn(Schedulers.io())
                .blockingSingle();

Response receiving in BaseServiceProxy

Request request = requestWaitQueue.remove(response.getNonce());
            if(request == null) {
                Log.warn("no mapped request exists : {}", response);
                return;
            }
            synchronized (request) {
                request.setResponse(response);
                request.notifyAll(); // wakeup waiting thread
            }