Fixed synchronization in LineProtocolParser

Author: bedrin

gradle/wrapper/gradle-wrapper.properties

@@ -1,5 +1,6 @@
+#Sat Mar 24 19:28:43 MSK 2018
 distributionBase=GRADLE_USER_HOME
 distributionPath=wrapper/dists
-distributionUrl=https\://services.gradle.org/distributions/gradle-4.6-bin.zip
 zipStoreBase=GRADLE_USER_HOME
 zipStorePath=wrapper/dists
+distributionUrl=https\://services.gradle.org/distributions/gradle-4.6-all.zip

parser/src/main/kotlin/io/sniffy/influxdb/parser/LineProtocolParser.kt

@@ -13,19 +13,21 @@ class LineProtocolParser(private val reader: Reader, private val failFast: Boole
     private val sb = StringBuilder()
     private val sb2 = StringBuilder()
 
-    @Volatile private var nextPoint: Point? = null
+    private var nextPoint: Point? = null
 
     constructor(string: String, failFast: Boolean = false) :
             this(StringReader(string), failFast)
 
     constructor(inputStream: InputStream, failFast: Boolean = false) :
             this(InputStreamReader(inputStream, Charsets.UTF_8), failFast)
 
+    @Synchronized
     override fun hasNext(): Boolean {
         nextPoint = parseNext()
         return nextPoint != null
     }
 
+    @Synchronized
     override fun next(): Point {
         return nextPoint ?: throw NoSuchElementException()
     }
@@ -61,8 +63,7 @@ class LineProtocolParser(private val reader: Reader, private val failFast: Boole
 
     }
 
-    internal @Synchronized
-    fun parseNext(): Point? {
+    private fun parseNext(): Point? {
 
         val builder = Point.Builder()