Functional Reactive Programming en Java

Citation:

---

Envoyé par thierryler

Regarde le sujet sur Algoid et tu vas voir que t'es pas seul ;-)

---

Voui j'ai vu.
Je te remercie d'ailleurs de ta relecture. Je porte les corrections demain. :mouarf:

Citation:

---

Envoyé par CyaNnOrangehead

Pour le schemat, merci.
Il faudrai que j'ajoute la légende suivante:
S1, S2 -> signal 1 et 2
sf1 sf1 -> signal function 1 et 2

Exemple d'interprétation du filter :
Le Signal 1 émet vers le signal 2.
Le signal est filtré pas une signalFunction qui détermine si l’émission doit ce faire ou pas.

Exemple d'interprétation du map :
Le signal 1 émet vers le signal 2, la valeur du signal 1 est transformé au travers la signalFunction

Exemple d'interprétation du fold :
Le signal 1 émet vers le signal 2, la valeur du signal 1 est transformé en fonction de la valeur d'émission en cours et la précédente (dans le temps)

---

Je dois avouer que je comprends vachement mieux les schémas avec les explications :D
Bon, j'attendais d'avoir lu les 2 articles pour te faire un retour (ton article sur les foncteurs et l'article sur Scala.React), mais ça traine un peu (pas assez de temps dans une journée :aie:).
Cette façon de programmer est vraiment intéressante. Ça m'a bien épaté.
Il faut que je jette un oeil en profondeur sur tout ça, mais t'as déjà fait un gros boulot ! :ccool:

Petite remarque subsidiaire, comme tu as changé ton bitbucket, ça serait pas mal, soit de mettre à jour les liens dans les posts précédents, soit de faire un post récapitulatif. C'est toujours frustrant de se manger un 404 quand on clique sur un lien :?

Voilà, à+
Gueritarish

Bonjour Gueritarish.
Pour le lien, je te donne raison, mais je ne parviens pas à éditer un poste ultérieur.
Voici donc la nouvelle address Bitbucket

Hier, en essayant d'expliquer la FRP à un collègue, je me suis rendu compte que j'était confus, et qu'en fait c'est très simple.
Prenons l'exemple suivant en impératif classique :

Code:

---

1 2 3 4 5 6 7 8 9

int a = 0; int b = 0; int sum = a + b;   System.out.println (sum); // 0, jusqu'ici tout va bien a = 10; b = 10; System.out.println (sum); // 0, ça vas toujours ?

---

Montrez ça à n'importe quel non développeur (mon gamin de 12 ans par exemple) et il vous rie au nez :
"Hey papa, tu ne sais donc pas calculé : 10 + 10 ça fait 20 !!!!"

En programmation Réactive le même programme pourrait donner :

Code:

---

1 2 3 4 5 6 7 8 9

int a = 0; int b = 0; int sum = a + b;   System.out.println (sum); // 0, jusqu'ici tout va bien a = 10; b = 10; System.out.println (sum); // 20, ça vas mieux !

---

sum étant égale à a + b, si a ou b change son résultat devrait changé.
En fait, ça fait juste 50 ans que nous, pauvres développeurs, nous somme habituer à ce que la variable (pas si variable que ça du coup) ne change pas si ses opérandes venaient à être changés. En fait on c'est habituer à ce que, dans le temps, sum = a + b ne soit plus vérifiable si l'une de ses opérande était altérée.

Maintenant imaginons que notre ordinateur soit lui aussi réactif. Que ses états puissent changés dans le temps. Ce qui est le cas du curseur de la souris, de la touche du clavier et même du temps lui même.
Imaginons, avec un tel système que nous voulions écrire dans un label la position de notre souris :

Code:

---

1 2 3 4 5 6

int x = Mouse.posX; int y = Mouse.posY;   String text = "La position de la souris est (" + x + ", " + y + "); myLabel.setText (text);

---

Les variables posX et posY vont varier dans le temps de même que x et y. Cela vas provoquer la variation de la variable text.
Plus besoin de gérer un évènement sur la souris, c'est le système de donnée qui c'en charge.

C'est un peu ce que j'aimerai obtenir à terme dans mon ti langage AL.
En attendant j'aimerai déjà l'intégré à Java. D'ou ma petite librairie.

Maintenant un moyen d'intégrer cela dans un langage dont les états ne peuvent pas varier, est d'utiliser la FRP Functional Reactive Programming qui est une adaptation de cette idée dans les langages fonctionnels comme Haskell et un dialecte dérivé ELM.

Voilà, sinon une petite démonstration des capacités de ma tite librairie adapté aux jeux vidéos : [ame="http://www.youtube.com/watch?v=-tYmfA1qqnw"]React4J - game developpment[/ame]

Remarquez comme lorsque la fenêtre est redimensionné, tout reprend sa place.
La positions des étoiles est un ratio sur la taille de la fenêtre. Si elle varie, ce ratio est automatiquement recalculé.

Salut,

Juste un petit post pour te dire que je trouve ton travail remarquable.

Et même si je dois bien avouer ne pas avoir encore tout compris, les perspectives qu'offre ta librairie ont l'air très prometteuses.

Je vais donc suivre ton travail avec intérêt :ccool::ccool:

@+

Merci nico, c'est motivant ! :ccool:

Citation:

---

Envoyé par CyaNnOrangehead

Pas tant que cela car tes questions sont pertinentes (en plus comme ça je me sens moins seul snirfff :cry::cry::cry::cry:)

---

Citation:

---

Envoyé par CyaNnOrangehead

1 - oui, à la sauce Haskell (fonctionel), c'est à dire en partant de librairies comme react banana. Ou le langage elm fonctionel également.

---

Désolé je connais pas :? Dans le domaine de la programmation concurrente et distribuée, je sais qu'Erlang est très réputé mais je ne m'y suis pas encore essayé.

Citation:

---

Envoyé par CyaNnOrangehead

2 - Le nom n'est peu-t-être pas très bien choisi. C'est la gestion d'un évenement. Un pattern observer mais qui n'accepte pas des listeners mais une "procedure" càd une fonction sans retour

---

En fait je vois pas trop en quoi c'est différent d'Observer et ses Listener. React devrait plutôt s'appeler Dispatcher. Regarde du côté de java.awt.EventQueue et java.awt.EventDispatchThread.

Citation:

---

Envoyé par CyaNnOrangehead

3 - MouseReact().move().merge(new MouseReact().click(), new Function2 ... mergeFunction);
On merge deux signaux mouse move et mouse click, et on traite les deux signaux d'entrée avec le foncteur mergeFunction. Du coup on as qu'une valeur de retour à chaque fois.

---

Une construction du type or(function, onPressed(), onMove()) m'aurait paru plus compréhensible.

Citation:

---

Envoyé par CyaNnOrangehead

5 - Question très pertinente :
merge, emet les deux signaux chaque fois que l'un des signal d'entrée à emit.
sync, n'emet les deux signaux que lorsque les deux signaux d'entrée ont emit.
then, n'émet les deux signaux que lorsque le premier suivi du second ont emits
when, n'émet les deux signaux que lorsque le second suivi du premier ont emits.

---

Je te propose : or/merge, and/join, after, before.

Citation:

---

Envoyé par CyaNnOrangehead

7 - En FRP il y a trois notion :
Les Variables, qui varient dans le temps et ont une valeur d'initialisation.
Les Signal, qui varient dans le temps mais ne possèdent pas de valeur initial (comme mouse button, time every etc.)
Les constants, des valeurs qui ne varient plus mais ont une valeur initial

---

Et donc le toVar sert à ?

Citation:

---

Envoyé par CyaNnOrangehead

8 - J'ai du refactoré, ils se nomment MouseReact.positionX et MouseReact.positionY maintenant

---

C'est quoi leur type ?

Citation:

---

Envoyé par CyaNnOrangehead

9 - L'exemple crée un signal en concatenant dans une chaine des infos sur la souris :
Si le bouton est pressé ou pas et la position.
button1 retourne un booléen qui est transformé en String par le map juste après.
Le toVar crée une variable et l'initialise avec une valeur par défaut
On merge avec positionX de la souris, que l'on mapFolt (les deux en même temps) càd que arg1 contient la chaine précédement obtenue et arg2 la position integer en X de la souris.
Idem avec la position en Y ensuite.

---

De ce que j'en comprends ca affiche "button [pressed|released] ( x=?, y=?)", je trouve pas ca du tout expressif par rapport à

Code:

---

1 2 3 4

merge( (Boolean buttonStatus, Point location) -> return "button " + (buttonStatus ? "pressed" : "released") + "( x=" + location.x + ", y=" + location.y + ")"), onButton1(), onMove());

---

non ?

Citation:

---

Envoyé par CyaNnOrangehead

Voilà. Ce qu'il faut comprendre en FRP c'est que l'idée derrière c'est que tout état du système doit pouvoir être vérifié à tout moment du programme comme vrai.
Exemple en pseudo code :
var a = 0;
var b = 0;
var sum = a + b;

print (sum); // 0
a = 7;
b = 8;
print (sum); // 15

En Java classique la dernière ligne écrirait 0.
Tout est là.
Après le reste c'est du traitement d'évènements, de la transformation (comme les liste en fonctionnel avec le map/filter/fold) et de la mise en réseau (d'ou mon petit schemat)

Vala.... Mais je suis d'accord avec toi, j'ai aussi mis un peu de temps au dépard pour bien comprendre de quoi il sagissait.

---

Ok, je comprends l'idée. D'ailleurs je pense que tu apprécieras la syntaxe de Ceylon :

Code:

---

1 2 3

Integer a = 0; Integer b = 0; Integer sum { return a + b };

---

Citation:

---

Envoyé par Gueritarish

Petite remarque subsidiaire, comme tu as changé ton bitbucket, ça serait pas mal, soit de mettre à jour les liens dans les posts précédents, soit de faire un post récapitulatif. C'est toujours frustrant de se manger un 404 quand on clique sur un lien :?

---

+1
Par ailleurs, ca serait bien de pouvoir consulter la javadoc en ligne et de pouvoir télécharger les sources sous forme d'archive. Ou alors les inclure dans le jar exécutable. Pas trop envie d'installer Mercurial et cloner le dépôt pour récupérer les sources correspondants aux binaires.

Citation:

---

Envoyé par Nemek

Ok, je comprends l'idée. D'ailleurs je pense que tu apprécieras la syntaxe de Ceylon :

Code:

---

1 2 3

Integer a = 0; Integer b = 0; Integer sum { return a + b };

---

---

Peu-t-on abonner un listener à sum en ceylon ?

Citation:

---

Envoyé par Nemek

+1
Par ailleurs, ca serait bien de pouvoir consulter la javadoc en ligne et de pouvoir télécharger les sources sous forme d'archive. Ou alors les inclure dans le jar exécutable. Pas trop envie d'installer Mercurial et cloner le dépôt pour récupérer les sources correspondants aux binaires.

---

Si c'est possible sans télécharger bitbucket (mais comme vous j'ai mis du temps pour trouver)
Va dans download, onglet tags il y a un petit lien zip à coté du tag tip.
Allez je suis bon avec toi, voici le lien : https://bitbucket.org/yann_caron/react4j/get/tip.zip

Normalement la javadoc et les testes unitaires sont dedans. Tout n'est pas encore tout à fait terminé hein !

Pour le reste de tes remarques j'y reflechis et te redit.
Je vais sans doute revoir les noms, c'est une bonne idée. :ccool::ccool::ccool::ccool:

Pour les termes, je t'invite fortement à consulter le jargon BPMN et SysML qui traitent justement de "signaux" et de "processus".

EDIT: En y repesant le diagramme d'activité d'UML définit déjà ses concepts : decision/merge et fork/join.

Citation:

---

Envoyé par Nemek

En fait je vois pas trop en quoi c'est différent d'Observer et ses Listener. React devrait plutôt s'appeler Dispatcher. Regarde du côté de java.awt.EventQueue et java.awt.EventDispatchThread.

---

Je suis nul en choix de noms. Donc je prend.
En effet cette implémentation de FRP est dite discrete (event driven) d'autre sont en temps continue (en échantillonnant)

Citation:

---

Envoyé par Nemek

Une construction du type or(function, onPressed(), onMove()) m'aurait paru plus compréhensible.

---

Je retiens les noms
Mais que fait-on de TimeReact.once, TimeReact.every, TimeReact.framePerSecond et TimeReact.randomly ? Les noms conviennent il ?

Citation:

---

Envoyé par Nemek

Je te propose : or/merge, and/join, after, before.

---

Je prend after et before. Merge et Sync me plaisent bien.

Citation:

---

Envoyé par Nemek

Et donc le toVar sert à ?

---

Passer d'un signal (qui n'as pas de valeur, ce sont des instants) à une variable (qui à une valeur tout au long du temps et donc une à son initialisation)
J'ai mise le wiki à jours avec des joli schemats ICI

Citation:

---

Envoyé par Nemek

C'est quoi leur type ?

---

Signal<Integer>

Citation:

---

Envoyé par Nemek

De ce que j'en comprends ca affiche "button [pressed|released] ( x=?, y=?)", je trouve pas ca du tout expressif par rapport à

Code:

---

1 2 3 4

merge( (Boolean buttonStatus, Point location) -> return "button " + (buttonStatus ? "pressed" : "released") + "( x=" + location.x + ", y=" + location.y + ")"), onButton1(), onMove());

---

non ?

---

Oui c'est dejà le cas (mais c'est moins fonctionnel et ça n'illustre pas les fonctions d'ordre supérieures) :

Code:

---

1 2 3 4 5 6 7 8 9

final Var<Integer> x = MouseReact.onMoveX().toVar(0); // mouse x reactive position final Var<Integer> y = MouseReact.onMoveY().toVar(0); // mouse y reactive position   Operation<String> text = Operation.mergeOperation(() -> "mouse position (" + x.getValue() + ", " + y.getValue() + ")", x, y); // react text = "mouse position (" react x ", " react y ")"   text.subscribe((String textPosition) -> { System.out.println(textPosition); });

---

Merci encore pour tes remarques :ccool::ccool::ccool:

Citation:

---

Envoyé par CyaNnOrangehead

Je suis nul en choix de noms. Donc je prend.

---

Je comprends j'ai le même soucis ^^

Citation:

---

Envoyé par CyaNnOrangehead

Mais que fait-on de TimeReact.once, TimeReact.every, TimeReact.framePerSecond et TimeReact.randomly ? Les noms conviennent il ?

---

Ne sachant pas exactement à quoi correspondent "once" et "randomly", je ne me prononcerais pas. Sinon "every" c'est très bien et "framePerSecond", je le remplacerait peut-être "atRate" et toujours une notion de TimeUnit. Par exemple, [CODEINLINE=Java]TimeReact.atRate(2, TimeUnit.MINUTES)[/CODELINE] pour dire deux fois par minutes.

Citation:

---

Envoyé par Nemek

Je comprends j'ai le même soucis ^^

---

Affreux d'autant que c'est super important, ça impact directement la lisibilité du code

Citation:

---

Envoyé par Nemek

Ne sachant pas exactement à quoi correspondent "once" et "randomly", je ne me prononcerais pas. Sinon "every" c'est très bien et "framePerSecond", je le remplacerait peut-être "atRate" et toujours une notion de TimeUnit. Par exemple, [CODEINLINE=Java]TimeReact.atRate(2, TimeUnit.MINUTES)[/CODELINE] pour dire deux fois par minutes.

---

En fait TimeReact.once lance un thread qui s'execute qu'un fois au bout d'un moment
TimeReact.randomly, lange un thread et déclenche l'émission à des intervales aléatoires (bornées)

nb : L'idée de timeunit est bonne. Je vais regarder.
Il faut aussi que je profil un peu le tout histoire de voir si ça ne génère pas trop d'objet (un peu quand même ! Pas bon pour Android tout ça !)

Rhaaaa mince !!!! Ca ressemble étrangement !
http://docs.oracle.com/javafx/2/bind...ub-binding.htm

Pire encore, c'est carrément ça : https://github.com/Netflix/RxJava/wi...ng-Observables

J'avais vu qu'il existant cette lib, mais je n'avait pas trouvé sa page wiki.
C'est chose faite maintenant. Suis blazzzzéeuuu :cry::cry::cry::cry: ....

'fin bref, je me serais bien amusé ^_^

Ca n'empeche pas de faire un article pour présenter le concept. Et tout le travail fournit permet de bien comprendre le concept et l'étendu de sa complexité en termes d'implémentation.
Dans le cadre d'un article, ca permet de présenter une implémentation avec la bonne direction vu que tu connais les pièges.
Bref, je pense pas que ce travail était une perte de temps.

Citation:

---

Envoyé par Nemek

Bref, je pense pas que ce travail était une perte de temps.

---

Tout à fait !
J'ai un peu fait joujou avec RxJava cet aprèm, c'est trait pour trait ce que j'ai fait. En mieux évidemment! La gestion des émission par subscriber est super bien pensé et les 3 évènements distincts next / finish et error permettent d'entrevoir des trucs sympa.

Le seul truc qui leur manque d'après ce que j'ai vu, c'est des "sujets" comme ils les appellent qui génère des évènements en fonction des évènements systèmes comme clock, mouse, keyboard. Eux sembles ce focaliser sur des listes et des suite d'évènements finis.

Je me suis amusé à créer un timer, ça joue nickel.

Il y a même un moyen de faire les opérations que j'ai cités dans mon article.
Leur approche est même bien meilleur que celle de java avec les bindings qui j'ai cité 3 postes plus haut.

Bref, je continue mon investigation.
Je suis en train de regarder pour coller cette librairie avec une librairie de jeux vidéos. Pour reproduire mon petit space invader maison. :ccool:
L'idée serait à terme de faire du reactive game programming.