core/io.github.easynearby.core.connection/DirectConnection

DirectConnection

class DirectConnection(val id: String, val name: String, receiveFlow: Flow<ByteArray>) : Connection

Direct implementation of Connection.

Constructors

DirectConnection

constructor(id: String, name: String, receiveFlow: Flow<ByteArray>)

Properties

open override val id: String

open override val name: String

Functions

open suspend override fun close()

Closes the connection

open operator override fun equals(other: Any?): Boolean

open suspend override fun getPayload(): Flow<ByteArray>

Returns a Flow of payloads received from a remote endpoint. Once connection is closed the flow will complete

open override fun hashCode(): Int

open suspend override fun sendPayload(payload: ByteArray): Result<Unit>

Sends a payload to a remote endpoint