io.ktor.network.sockets

Class SocketsKt

io.ktor.network.sockets.SocketsKt

public class SocketsKt

Method Summary

Modifier and Type	Method and Description
static java.lang.Object	awaitClosed(ASocket $receiver, kotlin.coroutines.experimental.Continuation<? super kotlin.Unit> p) Await until socket close
static boolean	isClosed(ASocket $receiver) Check if the socket is closed
static kotlinx.coroutines.io.ByteReadChannel	openReadChannel(AReadable $receiver) Open a read channel, could be done only once
static kotlinx.coroutines.io.ByteWriteChannel	openWriteChannel(AWritable $receiver, boolean autoFlush) Open a write channel, could be opened only once

Method Detail

isClosed

public static boolean isClosed(ASocket $receiver)

Check if the socket is closed

awaitClosed

public static java.lang.Object awaitClosed(ASocket $receiver,
                                           kotlin.coroutines.experimental.Continuation<? super kotlin.Unit> p)

Await until socket close

openReadChannel

public static kotlinx.coroutines.io.ByteReadChannel openReadChannel(AReadable $receiver)

Open a read channel, could be done only once

openWriteChannel

public static kotlinx.coroutines.io.ByteWriteChannel openWriteChannel(AWritable $receiver,
                                                                      boolean autoFlush)

Open a write channel, could be opened only once

Parameters:

autoFlush - whether returned channel do flush for every write operation