aboutsummaryrefslogtreecommitdiff
path: root/flow-main/src/main/scala/com/github/jodersky/flow/internal/SerialConnection.scala
diff options
context:
space:
mode:
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.scala17
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
+}