мне проще потратиться на десяток таких нод и получить честный канал в 1 гигабит, а потом обрабатывать и крутить данные уже на машинках хороших многоядерных физиках

с каждым десятком соответственно экономия на лицо и хлеб с маслом)

если бы еще кто препроцессор приделал, чтобы автовыведение типов слегка работало - тогда на плюсах будет почти также приятно писать как на скале.

https://asynchttpclient.github.io/async-http-client/request.html есть API для принятия чанков ответа

Некоторые либы (тот же WS) для простоты сохраняют весь респонс в памяти из-за того, что основной юз-кейс работы с ними – это манипуляции с ответом. Но никто не запрещает работать с чанками напрямую, аллоцируете фиксированый байтовый массив, FileOutputStream и погнали

его в Play в качестве дефолтного клиента запилили, кстати

т.е. под капотом WS вот оно

Да я вот как раз смотрю как они соединены

Используется AsyncCompletionHandler который буфферизирует респонс

Есть даже ResumableRandomAccessFileListener, используя который вместе с ResumableAsyncHandler сходу умеет асинхронно почанково сохранять файлы

https://jfarcand.wordpress.com/2011/01/04/going-asynchronous-using-asynchttpclient-the-complex/

CURL'у привет

тогда уж cURL'у скорее))

на фоне

а что этро

http://jokerconf.com

коллеги подскажите пожалуйста на сколько это идиотизм или нет

def getResultFields(fieldName: String, qRes: List[SObject]): List[Option[String]] = { qRes match { case Nil => List() case x :: xs => Option(x.getChild(fieldName)) match { case Some(y) => Option[y.getValue.asInstanceOf[String]] :: getResultFields(fieldName, xs) case _ => List() } } }

дело в том что у точно имеет поле getValue

что такое qRes ?

но компилятор жалуется

оффтопчик, просто название не о чем)

список обьектов форса

ок ^^

а что возвращает Option(x.getChild(fieldName))

и первый раз вижу, чтобы писали Option(some)

используют же как Some(value) или None

а еще непонятно про Option[] а внутри ты ему значение вместо типа кидаешь

бля!

def getResultFields(fieldName: String, qRes: List[SObject]): List[Option[String]] = { qRes match { case Nil => List() case x :: xs => Option(x.getChild(fieldName)) match { case Some(y) => Option[y.getValue.asInstanceOf[String]] :: getResultFields(fieldName, xs) case _ => List() } } }

вложенный матчинг лучше писать через for comprehension {} ну и кастовать ничо не надо - это зашквар.

спасибо, да в этом дело =)

на правах общего троллинга, конечно.

Коллеги, есть среди вас знатоки gradle?

не вопрос =)

def getResultFields(fieldName: String, qRes: List[SObject]): List[Option[String]] = { qRes match { case Nil => List() case x :: xs => Option(x.getChild(fieldName)) match { case Some(y) => Option(y.getValue.asInstanceOf[String]) :: getResultFields(fieldName, xs) case _ => List() } } }

вот теперь по стилю троллинг приветствуется

qRes match { case Nil => List() case x ну типа for { head <- qres.headOption; … }

оказывается у опшина есть апплай, почему-то никогда его не замечал) век живи, век учись)

а там xs тоже используется. надо думать. щааа открою такой воркшит и подумаю еба

гы сорри, нубостайл

как одерский в курсе научил делать все с первых принципов вместа библиотеки так и пишем...

Как минимум хорошо бы хвостовую рекурсию тут использовать def getResultFields(fieldName: String, qRes: List[SObject], acc: List[Option[String]] = Nil): List[Option[String]] = { qRes match { case Nil => Nil case x :: xs => Option(x.getChild(fieldName)) match { case Some(y) => getResultFields(fieldName, xs, Option(y.getValue.asInstanceOf[String]) :: acc) case _ => Nil } } }

дело в том что fieldName и getValue могут вернуть nullpointer

qRes - что такое q? что такое Res - Response, Resources? - обфусцируй как бог)

queryResponse

там же тип указан, думаю не важно как ее назвать =)

сферический лист с обьектами

btw: А есть ли вообще смысл в List[Option[String]]? Почему не просто Seq[String]?

в результате прилетел null - List(None, Some(Vasiliy Yur), Some(Kirill Avramenko))

я решил засунуть в Option на всякий

там обьекты кастомные - нет на них описания полей

А зачем в List[String] пихать None?

Я бы не использовал Option тут, смысла нет def getResultFields(fieldName: String, qRes: List[SObject], acc: List[Option[String]] = Nil): List[String] = { qRes match { case Nil => Nil case x :: xs => Option(x.getChild(fieldName)) match { case Some(y) => getResultFields(fieldName, xs, Option(y.getValue.asInstanceOf[String]),map(v => v:: acc).getOrElse(acc)) case _ => Nil } } }

аа интересно, спасибо

по поводу хвостовой - селект ограничен 100 результатами, но наверное не правильно такие вещи оставлять невявными

потом разограничят и будут думать почему упало =)

вложенный матчинг лучше писать через for comprehension {} ну и кастовать ничо не надо - это зашквар.

попробуй на фор переделать, читаемость ощутимо возрастет)

по поводу хвостовой - селект ограничен 100 результатами, но наверное не правильно такие вещи оставлять невявными

хвостовой рекурсии все равно сколько результатов. на то она и хвостовая, что компилятором раскладывается в обычный цикл

def getResultFields(fieldName: String, qRes: List[SObject]): List[Option[String]] = { qRes match { case Nil => List() case x :: xs => Option(x.getChild(fieldName)) match { case Some(y) => Option(y.getValue.asInstanceOf[String]) :: getResultFields(fieldName, xs) case _ => List() } } }

def getResultFields2(fieldName: String, qRes: List[SObject]): List[Option[String]] = { qRes.map(elem => Some(elem.getChild(fieldName).getValue.asInstanceOf[String])) }

зачем там вообще рекурсия.

Some ему не подойдет, там нулл же может быть он писал вроде

ага

на getValue

ну поставлю там Option

Option(null) = None

ERROR: S client not available

Some(null) = смешная скала-шутка

немного ничего

мб вообще тогда лучше exception ловить и Either?

Тогда уж лучше Try()

Но возвращать придется Seq[Try[String]], что опять же имеет смысл, если ты хочешь эти ошибки как-то обработать

логировать если только

а в чем смысл использовать Seq вместа List в таком случае? он же просто выше

Option(x.getChild(fieldName)) match { case Some(y) => getResultFields(fieldName, xs, Option(y.getValue.asInstanceOf[String]),map(v => v:: acc).getOrElse(acc)) case _ => Nil } а вобще, меня очень сильно смущает алгоритм который вроде бы выполняет функцию map, но при этом решение о продолжении принимает либо по окончанию входящего списка, либо по другому условию с размером входящего списка не связанному

@theLXK ни в чем на самом деле, по привычке написал :)

у тебя же Option(x.getChild(fieldName)) - может нулл вернуть и ты выйдешь из функции, хотя во входящем списке еще тонна элементов останется

странно как-то все

ага согласен

вообще наверное проще удалить и писать с нуля мэпом чтоб не зацикливатся

no pun intended

я бы начал с нормального названия метода, который бы отражал что он в действительности делает

затем переменные и результат на выходе, а потом может и тело метода станет совсем другим)

def chickiBrikiIVDamki(chiki: Briki): Damki

Mikhail поддержу, тут надо с логикой сначала разобраться, а потом уже с кодом

?

прям сразу вспомнились студенческие годы и дебиан на трех дисках

ок, спасибо за идеи

алтернатива вот такой чудесный скала код https://github.com/rajdeepd/force-rest-scala

class Util { def getAccessToken() : String = { val login = "https://login.salesforce.com/services/oauth2/token" var access_token = "" try { val conf = ConfigFactory.load() val UserName = conf.getString("force.UserName") val PassWord = conf.getString("force.PassWord") val LoginURL = conf.getString("force.LoginURL") val GrantService = conf.getString("force.GrantService") val ClientID = conf.getString("force.ClientID") val ClientSecret = conf.getString("force.ClientSecret") val loginURL = LoginURL + GrantService + "&client_id=" + ClientID + "&client_secret=" + ClientSecret + "&username=" + UserName + "&password=" + PassWord val client = new DefaultHttpClient val post = new HttpPost(loginURL) val handler = new BasicResponseHandler(); val response = client.execute(post) println("response:" + response) val body = handler.handleResponse(response); println(response) val gson = new Gson val jsonObject = gson.fromJson(body, classOf[Token]) access_token = jsonObject.access_token println("access_token: " + access_token) } catch { case ioe: java.io.IOException => case ste: java.net.SocketTimeoutException => } return access_token } }

я вдруг понял что SO - это первывй буквы SOAP. прям как на картинках when you understand you shit the brick

алтернатива вот такой чудесный скала код https://github.com/rajdeepd/force-rest-scala

не советую использовать return

в скале про return вобще лучше забыть

да тав вообще скала

только в название либы

есть такой нюанс, что оно реализовано через Exception)

;

и при определенной композиции функции и использовании return в каком-то месте - можно получить случайно выход там, где не ждешь