Event Based crap

[vendethiel]

Tight event-loop.

trait Event {
  type EventFuture = Future[Seq[Any]]
  val events: Seq[Symbol]
  val handlers = Map[Symbol, mutable.ListBuffer[() => Unit]]

  def subscribe(evt: Symbol, handler: () => Unit) {
    if (!events contains evt)
      throw new InvalidArgumentException(s"event $evt non existing")
    if (!handlers contains evt)
      handlers(evt) = mutable.ListBuffer[() => Unit]()

    handlers(evt) += handler
  }

  private def emit(evt: Symbol, o: Option[_] = None): EventFuture {
    ?
  }
}
class Character {
  def fightStart {
    fight = Fight(this)
    fight.subscribe('end, {someMethod()})
  }

  def someMethod {
  }
}
case class Fight(char: Character) extends Event {
  override val events = Seq('end)

  def onEnd { // called by some handler
    emit 'end
  }
}

[volgar1x]

How about this https://gist.github.com/Blackrush/7345399 but users have to pass an Executor to get emit asynchronous which is very odd

[vendethiel]

C'est une implem. details qui leak :(.

[vendethiel]

Et j'aime bien l'idée de check que c'est un event qui peut être emit même si sans compile time check c'est pas super utile

[volgar1x]

Où ça ça leak ? Pour le check des events faudrait les définir avant d'emit

[vendethiel]

implicit val executor = Executors.newSingleThreadExecutor()

la classe/l'objet devraient pas avoir à s'occuper de ça

[volgar1x]

Ouais, d'où mon commentaire plus haut mais je doute qu'un seul Executor pour toute la VM fasse l'affaire

[vendethiel]

Mettre sa création dans le constructeur d'Event ?

[volgar1x]

Un Thread par Observable ? Bof bof

[vendethiel]

:(. même faire un pool par type serait juste faire le devin ...

[volgar1x]

D'un autre côté, est-ce que c'est si important qu'emit soit asynchrone ?

[vendethiel]

Your idea ;)

[volgar1x]

Oui j'sais bien :D mais j'voulais savoir ton avis

[vendethiel]

non je pense pas que ça soit très important, et au pire on peut faire un overload AsyncObservable plus tard si le besoin s'en fait sentir.

[volgar1x]

Voilà c'est fait, j'ai ajouté une méthode 'emitted' pour marquer les events potentiellement déclenchés. J'commit des que j'ai un accès internet.

[vendethiel]

k nice :).

[volgar1x]

Look b2c7a7c j'aime pas du tout Lid mais j'savais pas comment faire autrement.

[vendethiel]

Pourquoi t'en as vraiment besoin ? Pourquoi def event = self ?

[volgar1x]

def event = self c'était dans l'ancienne API, Lid te permet d'unsubscribe un event. Je ne peux pas simplement me baser sur le hash de Listener qui peut changer (je pense notamment aux fonctions currifiées comme par exemple dans HandlerComponent.scala)

[vendethiel]

oui j'ai bien répondu après :(.