equal
deleted
inserted
replaced
294 private var futures = Map.empty[String, Future[Unit]] |
294 private var futures = Map.empty[String, Future[Unit]] |
295 |
295 |
296 override def init(session: Session): Unit = |
296 override def init(session: Session): Unit = |
297 synchronized { this.session = session } |
297 synchronized { this.session = session } |
298 |
298 |
299 override def exit(): Unit = synchronized { |
299 override def exit(exit_state: Document.State): Unit = synchronized { |
300 for ((id, future) <- futures) cancel(id, future) |
300 for ((id, future) <- futures) cancel(id, future) |
301 futures = Map.empty |
301 futures = Map.empty |
302 } |
302 } |
303 |
303 |
304 private def result(id: String, tag: Scala.Tag, res: List[Bytes]): Unit = |
304 private def result(id: String, tag: Scala.Tag, res: List[Bytes]): Unit = |