Play Framework 2.0.x> 2.1-RC göç

Question

Oynat 2.0.4 benim programda ben bu kod parçası vardı:

val channel = Enumerator.imperative[JsValue](onStart = self ! NotifyJoin(username)) 

ve şimdi imperative kullanımdan kaldırıldı söylüyor ve API diyor ben Bunun yerine unicast veya broadcast kullanmalısınız. unicast kullanıyorum çünkü kodumda channel tek noktaya yayın vardı. Bu yüzden

val channel = Concurrent.unicast[JsValue](onStart = self ! NotifyJoin(username)) 

gibi yapmak Ama bu unicast başka bir şey istiyor gibi .. görünüyor çalışmıyor. Anlayamıyorum - API'da daha fazla bilgi yok ... burada ne yapılacağını bilen var mı?

GÜNCELLEME:

Çal Çerçeve kullanıcı grubundaki bir tartışma başladı. Paradigmayı bilen geliştiriciler arasında oldukça yaygın bir sorun olduğu ortaya çıkıyor. Belgelerin geliştirileceğini umuyoruz.

Answer 1

Concurrent.unicast API geçerli:

unicast[E](onStart: (Channel[E]) ⇒ Unit, onComplete: ⇒ Unit, onError: (String, Input[E]) ⇒ Unit): Enumerator[E] 

Concurrent.broadcast API olmaktadır:

http://localhost:9000/@documentation/api/scala/index.html#play.api.libs.iteratee.Concurrent$ 

Answer 2

Örnek:

broadcast[E]: (Enumerator[E], Channel[E]) 

En uygulamanızda API alabilirsiniz Tek Noktaya Yayın kullanarak:

// here is an enumerator that returns a chunk to the channel 
val outEnumerator = Concurrent.unicast[JsValue] { channel => 
    val data = Json.obj("data" -> 12345) 
    channel.push(data) 
} 

eski Enumerator.imperative kullanarak alternatif generateM kullanmaktır: Burada

val out = Enumerator.generateM[JsValue] { 
    Promise.timeout({ 
     Some(Json.obj("data" -> 12345)) 
    }, 100, TimeUnit.MILLISECONDS) 
} 

, bir zaman aşımı kullanılarak yinelenen bir değer üretir. Bu numaralayıcı sonsuza kadar tekrarlanır, ancak generateM, bittiğinde belirtmek için Hiçbiri'ye dönmenize izin verir.