1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20 package org.apache.mina.core.future;
21
22 import org.apache.mina.core.session.IoSession;
23
24
25
26
27
28
29
30 public class DefaultCloseFuture extends DefaultIoFuture implements CloseFuture {
31
32
33
34 public DefaultCloseFuture(IoSession session) {
35 super(session);
36 }
37
38 public boolean isClosed() {
39 if (isDone()) {
40 return ((Boolean) getValue()).booleanValue();
41 } else {
42 return false;
43 }
44 }
45
46 public void setClosed() {
47 setValue(Boolean.TRUE);
48 }
49
50 @Override
51 public CloseFuture await() throws InterruptedException {
52 return (CloseFuture) super.await();
53 }
54
55 @Override
56 public CloseFuture awaitUninterruptibly() {
57 return (CloseFuture) super.awaitUninterruptibly();
58 }
59
60 @Override
61 public CloseFuture addListener(IoFutureListener<?> listener) {
62 return (CloseFuture) super.addListener(listener);
63 }
64
65 @Override
66 public CloseFuture removeListener(IoFutureListener<?> listener) {
67 return (CloseFuture) super.removeListener(listener);
68 }
69 }