1 files changed, 27 insertions, 0 deletions
diff --git a/src/main/scala/Client/ReceivedLineParser.scala b/src/main/scala/Client/ReceivedLineParser.scala
new file mode 100644
index 0000000..7cbf935
--- /dev/null
+++ b/src/main/scala/Client/ReceivedLineParser.scala
@@ -0,0 +1,27 @@
+package o1game.Client
+
+import scala.collection.mutable.Buffer
+import o1game.constants.*
+
+/** A class for checking asynchronously for received lines */
+class ReceivedLineParser:
+
+	private var serverLineState = ServerLineState.ActionDescription
+
+	private var bufferedData: Buffer[Byte] = Buffer.empty // TODO: suboptimal DS
+
+    /** Add received data */
+	def in(data: Array[Byte]): Unit =
+		this.bufferedData ++= data
+	
+    /** Read a line from the received data */
+	def nextLine(): Option[String] =
+		val indexOfCRLF = this.bufferedData.indexOfSlice(CRLF)
+		if indexOfCRLF == -1 then
+			None
+		else
+			val splitData = this.bufferedData.splitAt(indexOfCRLF)
+			this.bufferedData = Buffer.from(splitData(1).drop(CRLF.length))
+			Some(String(splitData(0).toArray))
+
+end ReceivedLineParser