From 55bb7fcc3ba7c303774f7671eda82293bf2f6fef Mon Sep 17 00:00:00 2001 From: Greg Giacovelli Date: Wed, 22 Dec 2021 14:35:52 -0800 Subject: [PATCH] No need to rename files --- .../streamadapter/coroutines/CoroutinesStreamAdapterFactory.kt | 2 +- ...{ReceiveChannelAdapter.kt => ReceiveChannelStreamAdapter.kt} | 2 +- ...ReceiveChannelTest.kt => ReceiveChannelStreamAdapterTest.kt} | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) rename scarlet-stream-adapter-coroutines/src/main/java/com/tinder/streamadapter/coroutines/{ReceiveChannelAdapter.kt => ReceiveChannelStreamAdapter.kt} (77%) rename scarlet-stream-adapter-coroutines/src/test/java/com/tinder/scarlet/streamadapter/coroutines/{ReceiveChannelTest.kt => ReceiveChannelStreamAdapterTest.kt} (98%) diff --git a/scarlet-stream-adapter-coroutines/src/main/java/com/tinder/streamadapter/coroutines/CoroutinesStreamAdapterFactory.kt b/scarlet-stream-adapter-coroutines/src/main/java/com/tinder/streamadapter/coroutines/CoroutinesStreamAdapterFactory.kt index 49b77d6c..33f18724 100644 --- a/scarlet-stream-adapter-coroutines/src/main/java/com/tinder/streamadapter/coroutines/CoroutinesStreamAdapterFactory.kt +++ b/scarlet-stream-adapter-coroutines/src/main/java/com/tinder/streamadapter/coroutines/CoroutinesStreamAdapterFactory.kt @@ -24,7 +24,7 @@ class CoroutinesStreamAdapterFactory( override fun create(type: Type): StreamAdapter { return when (type.getRawType()) { Flow::class.java -> FlowStreamAdapter(bufferSize) - ReceiveChannel::class.java -> ReceiveChannelAdapter(bufferSize) + ReceiveChannel::class.java -> ReceiveChannelStreamAdapter(bufferSize) else -> throw IllegalArgumentException() } } diff --git a/scarlet-stream-adapter-coroutines/src/main/java/com/tinder/streamadapter/coroutines/ReceiveChannelAdapter.kt b/scarlet-stream-adapter-coroutines/src/main/java/com/tinder/streamadapter/coroutines/ReceiveChannelStreamAdapter.kt similarity index 77% rename from scarlet-stream-adapter-coroutines/src/main/java/com/tinder/streamadapter/coroutines/ReceiveChannelAdapter.kt rename to scarlet-stream-adapter-coroutines/src/main/java/com/tinder/streamadapter/coroutines/ReceiveChannelStreamAdapter.kt index 50a980f9..fc52d3af 100644 --- a/scarlet-stream-adapter-coroutines/src/main/java/com/tinder/streamadapter/coroutines/ReceiveChannelAdapter.kt +++ b/scarlet-stream-adapter-coroutines/src/main/java/com/tinder/streamadapter/coroutines/ReceiveChannelStreamAdapter.kt @@ -4,7 +4,7 @@ import com.tinder.scarlet.Stream import com.tinder.scarlet.StreamAdapter import kotlinx.coroutines.channels.ReceiveChannel -class ReceiveChannelAdapter(private val buffer: Int) : StreamAdapter> { +class ReceiveChannelStreamAdapter(private val buffer: Int) : StreamAdapter> { override fun adapt(stream: Stream): ReceiveChannel { val channelForwarder = ChannelForwarder(buffer) diff --git a/scarlet-stream-adapter-coroutines/src/test/java/com/tinder/scarlet/streamadapter/coroutines/ReceiveChannelTest.kt b/scarlet-stream-adapter-coroutines/src/test/java/com/tinder/scarlet/streamadapter/coroutines/ReceiveChannelStreamAdapterTest.kt similarity index 98% rename from scarlet-stream-adapter-coroutines/src/test/java/com/tinder/scarlet/streamadapter/coroutines/ReceiveChannelTest.kt rename to scarlet-stream-adapter-coroutines/src/test/java/com/tinder/scarlet/streamadapter/coroutines/ReceiveChannelStreamAdapterTest.kt index bf42a9c2..38462d43 100644 --- a/scarlet-stream-adapter-coroutines/src/test/java/com/tinder/scarlet/streamadapter/coroutines/ReceiveChannelTest.kt +++ b/scarlet-stream-adapter-coroutines/src/test/java/com/tinder/scarlet/streamadapter/coroutines/ReceiveChannelStreamAdapterTest.kt @@ -19,7 +19,7 @@ import kotlinx.coroutines.test.runTest import org.junit.Rule import org.junit.Test -class ReceiveChannelTest { +class ReceiveChannelStreamAdapterTest { @get:Rule val clientServerModel = object : ClientServerModel(Service::class.java) {