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 public class DefaultCloseFuture extends DefaultIoFuture implements CloseFuture {
30
31
32
33
34
35 public DefaultCloseFuture(IoSession session) {
36 super(session);
37 }
38
39
40
41
42 @Override
43 public boolean isClosed() {
44 if (isDone()) {
45 return ((Boolean) getValue()).booleanValue();
46 } else {
47 return false;
48 }
49 }
50
51
52
53
54 @Override
55 public void setClosed() {
56 setValue(Boolean.TRUE);
57 }
58
59
60
61
62 @Override
63 public CloseFuture await() throws InterruptedException {
64 return (CloseFuture) super.await();
65 }
66
67
68
69
70 @Override
71 public CloseFuture awaitUninterruptibly() {
72 return (CloseFuture) super.awaitUninterruptibly();
73 }
74
75
76
77
78 @Override
79 public CloseFuture addListener(IoFutureListener<?> listener) {
80 return (CloseFuture) super.addListener(listener);
81 }
82
83
84
85
86 @Override
87 public CloseFuture removeListener(IoFutureListener<?> listener) {
88 return (CloseFuture) super.removeListener(listener);
89 }
90 }