Fix an end of stream bug

Closed the output stream to inform the SA for end of data.
alphabox · Apr 3, 2018 · a51c643 · a51c643
1 parent c5e6aee
commit a51c643
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 3 deletions.
diff --git a/pom.xml b/pom.xml
@@ -3,7 +3,7 @@
 	<modelVersion>4.0.0</modelVersion>
 	<groupId>hu.alphabox</groupId>
 	<artifactId>spamc</artifactId>
-	<version>0.1-SNAPSHOT</version>
+	<version>0.2.0-SNAPSHOT</version>
 	<packaging>jar</packaging>
 
 	<name>spamc</name>

diff --git a/src/main/java/hu/alphabox/spamc/SAClient.java b/src/main/java/hu/alphabox/spamc/SAClient.java
@@ -106,8 +106,9 @@ public SAResponse sendRequest(SARequest request) throws SAException, IOException
 			InputStream inputStream = socket.getInputStream();
 
 			StringBuilder builder = new StringBuilder();
-			outputStream.write(request.getRequestByteArray().toByteArray());
-			outputStream.flush();
+
+			request.getRequestByteArray().writeTo(outputStream);
+			socket.shutdownOutput();
 
 			byte[] cache = new byte[1024];
 			while (inputStream.read(cache) != -1) {