Linting

onflow · Oct 1, 2024 · 703a5f6 · 703a5f6
1 parent e6f819a
commit 703a5f6
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 5 deletions.
diff --git a/...c/main/kotlin/org/onflow/examples/kotlin/streaming/streamEvents/SubscribeEventsExample.kt b/...c/main/kotlin/org/onflow/examples/kotlin/streaming/streamEvents/SubscribeEventsExample.kt
@@ -36,13 +36,13 @@ class SubscribeEventsExample(
                     if (events.isNotEmpty()) {
                         receivedEvents.addAll(events)
                     }
-                    yield()  // Ensure coroutine checks for cancellation
+                    yield()
                 }
             } catch (e: CancellationException) {
                 println("Data channel processing cancelled")
             } finally {
                 println("Data channel processing finished")
-                dataChannel.cancel()  // Ensure the channel is closed
+                dataChannel.cancel()
             }
         }
 

diff --git a/...org/onflow/examples/kotlin/streaming/streamExecutionData/SubscribeExecutionDataExample.kt b/...org/onflow/examples/kotlin/streaming/streamExecutionData/SubscribeExecutionDataExample.kt
@@ -9,7 +9,6 @@ import org.onflow.flow.sdk.crypto.PrivateKey
 class SubscribeExecutionDataExample(
     privateKey: PrivateKey,
     accessApiConnection: FlowAccessApi
-
 ) {
     private val accessAPI = accessApiConnection
     private val connector = AccessAPIConnector(privateKey, accessAPI)
@@ -67,4 +66,3 @@ class SubscribeExecutionDataExample(
         errorJob.join()
     }
 }
-
diff --git a/...st/kotlin/org/onflow/examples/kotlin/streaming/streamEvents/SubscribeEventsExampleTest.kt b/...st/kotlin/org/onflow/examples/kotlin/streaming/streamEvents/SubscribeEventsExampleTest.kt
@@ -33,7 +33,7 @@ internal class SubscribeEventsExampleTest {
         val receivedEvents = mutableListOf<FlowEvent>()
         try {
             val streamJob = launch {
-                withTimeoutOrNull(10_000L) {  // Set timeout to ensure test completes in a reasonable time
+                withTimeoutOrNull(10_000L) {
                     subscribeEventsExample.streamEvents(testScope, receivedEvents)
                 }
             }