korlibs-io/korlibs.io.net/FakeAsyncClient

FakeAsyncClient

class FakeAsyncClient(val serverToClient: SyncStream = DequeSyncStream(), val clientToServer: SyncStream = DequeSyncStream(), val onConnect: Signal<Pair<String, Int>> = Signal(), val onClose: Signal<Unit> = Signal()) : AsyncClient

Constructors

FakeAsyncClient

constructor(serverToClient: SyncStream = DequeSyncStream(), clientToServer: SyncStream = DequeSyncStream(), onConnect: Signal<Pair<String, Int>> = Signal(), onClose: Signal<Unit> = Signal())

Properties

open override val address: AsyncAddress

val clientToServer: SyncStream

open override var connected: Boolean

val onClose: Signal<Unit>

val onConnect: Signal<Pair<String, Int>>

val serverToClient: SyncStream

Functions

suspend fun AsyncInputStream.checksum(checksum: SimpleChecksum): Int

open suspend override fun close()

open suspend override fun connect(host: String, port: Int)

suspend fun AsyncInputStream.hash(algo: HasherFactory): Hash

suspend fun AsyncInputStream.md5(): Hash

open suspend override fun read(): Int

open suspend override fun read(buffer: ByteArray, offset: Int, len: Int): Int

suspend fun AsyncInputStream.sha1(): Hash

withChecksumUpdater

fun AsyncOutputStream.withChecksumUpdater(checksum: SimpleChecksumUpdater): AsyncOutputStream

withContentEncoding

suspend fun AsyncInputStream.withContentEncoding(contentEncoding: String): AsyncInputStream

withTransferEncoding

suspend fun AsyncInputStream.withTransferEncoding(transferEncoding: String): AsyncInputStream

open suspend override fun write(buffer: ByteArray, offset: Int, len: Int)

open suspend fun write(byte: Int)

suspend fun AsyncOutputStream.writeFile(source: VfsFile): Long