Skip to content

Commit 1dd4a7d

Browse files
committed
chore: cleanup
1 parent b431f8c commit 1dd4a7d

File tree

4 files changed

+6
-4
lines changed

4 files changed

+6
-4
lines changed

src/main/kotlin/dev/silenium/libs/flows/api/FlowGraphElement.kt

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -12,4 +12,5 @@ interface FlowGraphElement<T : Any> : AutoCloseable {
1212

1313
interface SourceFlowGraphElement<T, P, S : Source<T, P>> : FlowGraphElement<S>, Source<T, P>
1414
interface SinkFlowGraphElement<T, P, S : Sink<T, P>> : FlowGraphElement<S>, Sink<T, P>
15-
interface TransformerFlowGraphElement<IT, IP, OT, OP, T : Transformer<IT, IP, OT, OP>> : FlowGraphElement<T>, Transformer<IT, IP, OT, OP>
15+
interface TransformerFlowGraphElement<IT, IP, OT, OP, T : Transformer<IT, IP, OT, OP>> :
16+
FlowGraphElement<T>, Transformer<IT, IP, OT, OP>

src/main/kotlin/dev/silenium/libs/flows/base/SourceBase.kt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,8 @@
11
package dev.silenium.libs.flows.base
22

3-
import dev.silenium.libs.flows.impl.CloningFlow
43
import dev.silenium.libs.flows.api.FlowItem
54
import dev.silenium.libs.flows.api.Source
5+
import dev.silenium.libs.flows.impl.CloningFlow
66
import java.util.*
77

88
abstract class SourceBase<T, P> : Source<T, P> {

src/test/kotlin/dev/silenium/libs/flows/test/Base64Decoder.kt

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,6 @@
11
package dev.silenium.libs.flows.test
22

33
import dev.silenium.libs.flows.api.FlowItem
4-
import dev.silenium.libs.flows.api.Sink
54
import dev.silenium.libs.flows.api.Transformer
65
import dev.silenium.libs.flows.base.SourceBase
76
import kotlinx.coroutines.*

src/test/kotlin/dev/silenium/libs/flows/test/BufferSink.kt

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,9 @@ package dev.silenium.libs.flows.test
22

33
import dev.silenium.libs.flows.api.FlowItem
44
import dev.silenium.libs.flows.api.Sink
5-
import kotlinx.coroutines.flow.*
5+
import kotlinx.coroutines.flow.MutableStateFlow
6+
import kotlinx.coroutines.flow.StateFlow
7+
import kotlinx.coroutines.flow.asStateFlow
68

79
class BufferSink<T, P>(vararg pads: Pair<UInt, P>) : Sink<T, P> {
810
private val inputMetadata_: MutableMap<UInt, P?> = pads.toMap().toMutableMap()

0 commit comments

Comments
 (0)