Change Java future observable implementation from blocking to non blocking