diff options
Diffstat (limited to 'flow-main/src/main/scala/com/github/jodersky/flow/internal/SerialConnection.scala')
-rw-r--r-- | flow-main/src/main/scala/com/github/jodersky/flow/internal/SerialConnection.scala | 17 |
1 files changed, 9 insertions, 8 deletions
diff --git a/flow-main/src/main/scala/com/github/jodersky/flow/internal/SerialConnection.scala b/flow-main/src/main/scala/com/github/jodersky/flow/internal/SerialConnection.scala index b4242fe..73416e3 100644 --- a/flow-main/src/main/scala/com/github/jodersky/flow/internal/SerialConnection.scala +++ b/flow-main/src/main/scala/com/github/jodersky/flow/internal/SerialConnection.scala @@ -1,11 +1,9 @@ -package com.github.jodersky.flow.internal +package com.github.jodersky.flow +package internal import java.nio.ByteBuffer import java.util.concurrent.atomic.AtomicBoolean -import com.github.jodersky.flow.PortClosedException -import com.github.jodersky.flow.SerialSettings - /** * Represents a serial connection in a more secure and object-oriented style than `NativeSerial`. In contrast * to the latter, this class encapsulates and secures any pointers used to communicate with the native @@ -16,7 +14,8 @@ import com.github.jodersky.flow.SerialSettings class SerialConnection private ( val port: String, val settings: SerialSettings, - private val pointer: Long) { + private val pointer: Long +) { import SerialConnection._ @@ -74,7 +73,8 @@ class SerialConnection private ( try { transfer( b => NativeSerial.readDirect(pointer, b), - b => NativeSerial.read(pointer, b.array()))(buffer) + b => NativeSerial.read(pointer, b.array()) + )(buffer) } finally { reading = false if (closed.get) readLock.notify() @@ -105,7 +105,8 @@ class SerialConnection private ( try { transfer( b => NativeSerial.writeDirect(pointer, b, b.position()), - b => NativeSerial.write(pointer, b.array(), b.position()))(buffer) + b => NativeSerial.write(pointer, b.array(), b.position()) + )(buffer) } finally { writing = false if (closed.get) writeLock.notify() @@ -154,4 +155,4 @@ object SerialConnection { */ def debug(value: Boolean) = NativeSerial.debug(value) -}
\ No newline at end of file +} |