equal
deleted
inserted
replaced
158 class Handler extends Session.Protocol_Handler |
158 class Handler extends Session.Protocol_Handler |
159 { |
159 { |
160 private var session: Session = null |
160 private var session: Session = null |
161 private var futures = Map.empty[String, Future[Unit]] |
161 private var futures = Map.empty[String, Future[Unit]] |
162 |
162 |
163 override def init(init_session: Session): Unit = |
163 override def init(session: Session): Unit = |
164 synchronized { session = init_session } |
164 synchronized { this.session = session } |
165 |
165 |
166 override def exit(): Unit = synchronized |
166 override def exit(): Unit = synchronized |
167 { |
167 { |
168 for ((id, future) <- futures) cancel(id, future) |
168 for ((id, future) <- futures) cancel(id, future) |
169 futures = Map.empty |
169 futures = Map.empty |