Showing content from https://www.playframework.com/documentation/2.5.x/api/scala/play/api/libs/iteratee/Concurrent$.html below:
Concurrent - play.api.libs.iteratee.Concurrent
final def !=(arg0: Any): Boolean
final def ##(): Int
final def ==(arg0: Any): Boolean
final def asInstanceOf[T0]: T0
def broadcast[E](e: Enumerator[E], interestIsDownToZero: (Broadcaster) â Unit = _ => ())(implicit ec: ExecutionContext): (Enumerator[E], Broadcaster)
def broadcast[E]: (Enumerator[E], Channel[E])
def buffer[E](maxBuffer: Int, length: (Input[E]) â Int)(implicit ec: ExecutionContext): Enumeratee[E, E]
def buffer[E](maxBuffer: Int): Enumeratee[E, E]
def clone(): AnyRef
def dropInputIfNotReady[E](duration: Long, unit: TimeUnit = ...): Enumeratee[E, E]
final def eq(arg0: AnyRef): Boolean
def equals(arg0: Any): Boolean
def finalize(): Unit
final def getClass(): Class[_]
def hashCode(): Int
final def isInstanceOf[T0]: Boolean
def joined[A]: (Iteratee[A, Unit], Enumerator[A])
def lazyAndErrIfNotReady[E](timeout: Long, unit: TimeUnit = TimeUnit.MILLISECONDS): Enumeratee[E, E]
final def ne(arg0: AnyRef): Boolean
final def notify(): Unit
final def notifyAll(): Unit
def patchPanel[E](patcher: (PatchPanel[E]) â Unit)(implicit ec: ExecutionContext): Enumerator[E]
def runPartial[E, A](enumerator: Enumerator[E], iteratee: Iteratee[E, A]): Future[(A, Enumerator[E])]
final def synchronized[T0](arg0: â T0): T0
def toString(): String
def unicast[E](onStart: (Channel[E]) â Unit, onComplete: â Unit = (), onError: (String, Input[E]) â Unit = (_: String, _: Input[E]) => ())(implicit ec: ExecutionContext): Enumerator[E] { implicit val pec: scala.concurrent.ExecutionContext }
final def wait(): Unit
final def wait(arg0: Long, arg1: Int): Unit
final def wait(arg0: Long): Unit
RetroSearch is an open source project built by @garambo
| Open a GitHub Issue
Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo
HTML:
3.2
| Encoding:
UTF-8
| Version:
0.7.4