Skip to content

Commit

Permalink
No need to rename files
Browse files Browse the repository at this point in the history
  • Loading branch information
greggiacovelli committed Jan 4, 2022
1 parent d870756 commit a59de17
Show file tree
Hide file tree
Showing 3 changed files with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,7 @@ class CoroutinesStreamAdapterFactory(
override fun create(type: Type): StreamAdapter<Any, Any> {
return when (type.getRawType()) {
Flow::class.java -> FlowStreamAdapter(bufferSize)
ReceiveChannel::class.java -> ReceiveChannelAdapter(bufferSize)
ReceiveChannel::class.java -> ReceiveChannelStreamAdapter(bufferSize)
else -> throw IllegalArgumentException()
}
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@ import com.tinder.scarlet.Stream
import com.tinder.scarlet.StreamAdapter
import kotlinx.coroutines.channels.ReceiveChannel

class ReceiveChannelAdapter<T>(private val buffer: Int) : StreamAdapter<T, ReceiveChannel<T>> {
class ReceiveChannelStreamAdapter<T>(private val buffer: Int) : StreamAdapter<T, ReceiveChannel<T>> {

override fun adapt(stream: Stream<T>): ReceiveChannel<T> {
val channelForwarder = ChannelForwarder<T>(buffer)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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>(Service::class.java) {
Expand Down

0 comments on commit a59de17

Please sign in to comment.