1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16 package io.netty5.testsuite.transport.socket;
17
18 import io.netty5.util.internal.SocketUtils;
19
20 import java.io.IOException;
21 import java.net.Socket;
22 import java.net.SocketAddress;
23
24 public class SocketShutdownOutputByPeerTest extends AbstractSocketShutdownOutputByPeerTest<Socket> {
25
26 @Override
27 protected void shutdownOutput(Socket s) throws IOException {
28 s.shutdownOutput();
29 }
30
31 @Override
32 protected void connect(Socket s, SocketAddress address) throws IOException {
33 SocketUtils.connect(s, address, 10000);
34 }
35
36 @Override
37 protected void close(Socket s) throws IOException {
38 s.close();
39 }
40
41 @Override
42 protected void write(Socket s, int data) throws IOException {
43 s.getOutputStream().write(data);
44 }
45
46 @Override
47 protected Socket newSocket() {
48 return new Socket();
49 }
50
51 }