Свежевыжатый?

Да

И чем кстати?

И чем кстати?

Ну тип, ущемление рекрутеров

разжигание ненависти к социальной группе

у тебя сейчас телефон разрядится а, уже на зарядке, черт

Что такое понв

Отбой

Точно отбой?

не точно, что это?

Я не понял ничего

не точно, что это?

@scala_flood

@scala_flood

gotcha

@scala_flood

переименуйте в @scala_ponv

или в @ponv если Т позволяет 4 буквы, но кажется не позволяет

переименуйте в @scala_ponv

Ща, 5 сек

Джон де гоз да?

Давно пора скала-стикеры сделать.

Давно пора объявление сделать!

Давно пора объявление сделать!

Такой смелый, потому что не докладчик?

Такой смелый, потому что не докладчик?

Да, а ты?

5-6 апреля ничего не будет в Мск?

там java конфа, я бы вечером сходил очистится на митап, но видимо это заоблачные ожидания

Да, а ты?

Я тоже не докладчик, но ты всё равно офигел

Я тоже не докладчик, но ты всё равно офигел

Очень плохо с твоей стороны!

5-6 апреля ничего не будет в Мск?

будет 5го

давайте дружно позовем Фомкина, чтоб он запилил анонс наконец

Я тоже не докладчик, но ты всё равно офигел

Нет, ты офигел, раз не докладчик!

будет 5го

идеально, спасибо !

не идеально(

но пусть лучше будет чем не будет)

я проверил даты - тоже пролетаю, вся надежда на пивную встречу если она будет

гуавовая com.google.common.util.concurrent.ListenableFuture строгая или нет?

гуавовая com.google.common.util.concurrent.ListenableFuture строгая или нет?

строгая да

спасиб

пожалст

хм, значит имеет смысл при конвертации в таск ее сразу задеферрить?

def asTask[A](guavaFut: ListenableFuture[A]): Task[A] = Task.defer(Task.create { (_, cb) => val callback = new FutureCallback[A] { def onSuccess(a: A): Unit = cb.onSuccess(a) def onFailure(err: Throwable): Unit = cb.onError(err) } Futures.addCallback(guavaFut, callback) Cancelable.empty })

или я какй-то фигней занимаюсь, т.к. на входе она уже будет запущена

если так guavaFut: => ListenableFuture[A] ?

или я какй-то фигней занимаюсь, т.к. на входе она уже будет запущена

Всё правильно сделай, просто сделай бай -нейм и со скедулером, как в deferFuture и deferFutureAction

def asTask[A](guavaFut: ListenableFuture[A]): Task[A] = Task.defer(Task.create { (_, cb) => val callback = new FutureCallback[A] { def onSuccess(a: A): Unit = cb.onSuccess(a) def onFailure(err: Throwable): Unit = cb.onError(err) } Futures.addCallback(guavaFut, callback) Cancelable.empty })

И ещё важный аспект. У гуавовских (и вообще джавовых) фьюч есть cancel

Так что можно даже не empty возвращать, а реальный cancellable

И ещё, ставлю пять фомкинкоинов, что ты оборачиваешь com.datastax.driver

тру стори

Так уже мильон раз обернуто же )

Так уже мильон раз обернуто же )

чобы мильён первый не обернуть

Так уже мильон раз обернуто же )

но теперь это уж с ежом — квилл с инитом

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

Ну кстати вот здесь другая фьюча совсем https://github.com/monix/monix/blob/master/monix-java/src/main/scala/monix/java8/eval/package.scala#L41

бомбит от такого кол-ва фьюч в стд либ джовы

сказал человек, оборачивающий в Task, в репозитории, конвертящем из concurrent.Future и IO, с кодом скопированным из scalaz7 Task, scalaz8 IO и немножно twitter Future

аааа в std lib, я понял да

у нас в каждой либе по одной одной фьюча, просто количество либ ...

да взять вот комплитабл: понятно, что потенциально может быть neverending future, у моникса в кишках она наверняка есть для того же Task.never, но он при этом все равно возвращает Task, а не CompletableTask

ну насколько я понимаю, CompletableFuture - это наряду с guava SettableFuture аналог Promise

да взять вот комплитабл: понятно, что потенциально может быть neverending future, у моникса в кишках она наверняка есть для того же Task.never, но он при этом все равно возвращает Task, а не CompletableTask

что такое CompletableTask?

мой абсурдный домысел

ты, мне кажется, задумал что-то страшное

Это типа тотального таска? Гарантирующего ответ в течение какого-то времени?

Презентация Эрика об opaque types http://plastic-idolatry.com/erik/nescala2018.pdf

ты, мне кажется, задумал что-то страшное

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

ERROR: S client not available

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

ну я же говорю, это Promise у него есть complete и completeExceptionally

так же как у SettableFuture есть set и setException

но при этом мы все равно отдаем promise.future

ну я не знаю, насколько это продвинуло нас

тот факт, что на уровне интерфейсов - это не подтип

киселев.жпг

сказал человек, оборачивающий в Task, в репозитории, конвертящем из concurrent.Future и IO, с кодом скопированным из scalaz7 Task, scalaz8 IO и немножно twitter Future

Да, я тоже не смог понять почему они просто интерфейс Future не расширили

Да, я тоже не смог понять почему они просто интерфейс Future не расширили

?

Ой сорян не в тот комент ткнул

я чуть не подумал, что ты хотел monix.eval.Task extends scala.concurrent.Future

Эт я про жавку

Кто нибудь помнит где был гист на zero overhead Fix ?

там через какойто mind fuckery было сделано ))

я могу только свой кинуть

там через самодельные ньютайп

думаю смысл тот же

моё говно, не помню, сколько лет ему https://gist.github.com/Odomontois/f58ec94a7d85643ce74ae54301ad906b

Обновил там

полтора лет ему

Да прикольно, но там где я видел было более лаконично

ну ок

no offense

в ПОНВ поговорим

Коллеги, добрый день! На чем сейчас модно писать мобильные приложения?

котлин

на мокапах

нарисовал продал и убежал

Коллеги, добрый день! На чем сейчас модно писать мобильные приложения?

swift

нене, что бы на скале обязательно