Пример использования Scala ObservableSet Trait - PullRequest
Новая
       11

Пример использования Scala ObservableSet Trait

4 голосов
/ 31 мая 2010

Может ли кто-нибудь помочь мне рассказать, как использовать scala черта ?

Большое спасибо заранее

Ответы [ 2 ]

8 голосов
/ 31 мая 2010

ObservableSet - это черта, выходящая из черты Publisher , дающая некоторое базовое поведение подписки при публикации. Простой пример использования этого будет: 

scala> class Counter(var count: Int) extends Publisher[String] {
          def inc(): Unit = {
              count += 1
              super.publish("updated count to: " + count)
          }
     }

scala> class S[Evt, Pub] extends Subscriber[Evt, Pub] {
         def notify(pub: Pub, event: Evt): Unit = println("got event: " + event)
      }
defined class S

scala> val s = new S[String, Counter#Pub]     
s: S[String,Counter#Pub] = S@7c27a30c

scala> val c = new Counter(1)
c: Counter = Counter@44ba70c

scala> c.subscribe(s)

scala> c.inc
got event: updated count to: 2

ObservableSet делает нечто подобное, он вызывает метод publish, когда элементы добавляются или удаляются с помощью метода + = или + - см. Следующий пример (с классом S, определенным выше): 

scala> class MySet extends HashSet[Int] with ObservableSet[Int] {       
     override def +=(elem: Int): this.type = super.+=(elem);
     override def -=(elem: Int): this.type = super.-=(elem);
     override def clear: Unit = super.clear;      
}

defined class MySet

scala> val set = new MySet
set: MySet = Set()

scala> val subS = new S[Any, Any]
subCol: S[Any,Any] = S@3e898802

scala> set.subscribe(subS)

scala> set += 1
got event: Include(NoLo,1)
res: set.type = Set(1)

Я ленился, определяя S с типами Any, но я не смог сразу же правильно набрать текст и не потратил слишком много времени, пытаясь понять это.

2 голосов
/ 01 июня 2010

Со всей информацией о наборе текста это немного неприятно, но именно так я смог заставить ее работать. Я приветствую предложения о том, как сделать набор текста более лаконичным. различные правки, включая псевдонимы типов : 

import collection.mutable._
import collection.script._

val set = new HashSet[String] with ObservableSet[String] { }

type Msg = Message[String] with Undoable
type Sub = Subscriber[Msg, ObservableSet[String]]

val sub = new Sub() {
  def notify(pub: ObservableSet[String], event: Msg): Unit = {
    println("%s sent %s".format(pub, event))
    event match {
      case r:Remove[_] => println("undo!"); event.undo()
      case _ => 
    }
  }
}

set.subscribe(sub)

set += "foo"
set += "bar"
set -= "bar"

Что печатает: 

Set(foo) sent Include(NoLo,foo)
Set(bar, foo) sent Include(NoLo,bar)
Set(foo) sent Remove(NoLo,bar)
undo!
Set(bar, foo) sent Include(NoLo,bar)

Интересно, что отмена заставила опубликовать еще одно сообщение ...

...