aboutsummaryrefslogtreecommitdiff
path: root/vfd-dashboard/src/main/scala/vfd/dashboard/MavlinkSocket.scala
diff options
context:
space:
mode:
Diffstat (limited to 'vfd-dashboard/src/main/scala/vfd/dashboard/MavlinkSocket.scala')
-rw-r--r--vfd-dashboard/src/main/scala/vfd/dashboard/MavlinkSocket.scala24
1 files changed, 10 insertions, 14 deletions
diff --git a/vfd-dashboard/src/main/scala/vfd/dashboard/MavlinkSocket.scala b/vfd-dashboard/src/main/scala/vfd/dashboard/MavlinkSocket.scala
index dff3598..9476794 100644
--- a/vfd-dashboard/src/main/scala/vfd/dashboard/MavlinkSocket.scala
+++ b/vfd-dashboard/src/main/scala/vfd/dashboard/MavlinkSocket.scala
@@ -29,25 +29,21 @@ class MavlinkSocket(url: String, remoteSystemId: Int) {
}
private val parser = new Parser(
- pckt => {
- pckt match {
- case Packet(seq, `remoteSystemId`, compId, msgId, payload) =>
- packet() = pckt
- stats.packets() += 1
- case _ =>
- stats.wrongIds() += 1
- }
+ {
+ case pckt@Packet(seq, `remoteSystemId`, compId, msgId, payload) =>
+ packet() = pckt
+ stats.packets() += 1
+ case _ =>
+ stats.wrongIds() += 1
},
- err => {
- err match {
- case CrcError => stats.crcErrors() += 1
- case OverflowError => stats.overflows() += 1
- }
+ {
+ case CrcError => stats.crcErrors() += 1
+ case OverflowError => stats.overflows() += 1
})
private val connection = new dom.WebSocket(url)
- connection.binaryType = "arraybuffer";
+ connection.binaryType = "arraybuffer"
connection.onopen = (e: dom.Event) => {
stats.open() = true
}