return new DisconnectResponse(ResponseStatus.SUCCESS);
}
})
.subscribe(request.observable());
} else if (request instanceof GetClusterConfigRequest) {
request.observable().onNext(new GetClusterConfigResponse(configProvider.config(), ResponseStatus.SUCCESS));
request.observable().onCompleted();
}
}