Implement new connection handling
Showing
- client/build.gradle.kts 1 addition, 1 deletionclient/build.gradle.kts
- client/src/main/kotlin/de/justjanne/libquassel/client/session/ClientConnectionHandler.kt 40 additions, 0 deletions...anne/libquassel/client/session/ClientConnectionHandler.kt
- client/src/main/kotlin/de/justjanne/libquassel/client/session/ClientHandshakeHandler.kt 137 additions, 0 deletions...janne/libquassel/client/session/ClientHandshakeHandler.kt
- client/src/main/kotlin/de/justjanne/libquassel/client/session/ClientMagicHandler.kt 66 additions, 0 deletions...justjanne/libquassel/client/session/ClientMagicHandler.kt
- client/src/main/kotlin/de/justjanne/libquassel/client/session/ClientProxyMessageHandler.kt 19 additions, 8 deletions...ne/libquassel/client/session/ClientProxyMessageHandler.kt
- client/src/main/kotlin/de/justjanne/libquassel/client/session/ClientRpcHandler.kt 1 addition, 1 deletion...e/justjanne/libquassel/client/session/ClientRpcHandler.kt
- client/src/main/kotlin/de/justjanne/libquassel/client/session/ClientSession.kt 38 additions, 3 deletions...n/de/justjanne/libquassel/client/session/ClientSession.kt
- client/src/main/kotlin/de/justjanne/libquassel/client/session/ClientSessionState.kt 1 addition, 1 deletion...justjanne/libquassel/client/session/ClientSessionState.kt
- client/src/main/kotlin/de/justjanne/libquassel/client/util/CoroutineKeyedQueue.kt 33 additions, 0 deletions...e/justjanne/libquassel/client/util/CoroutineKeyedQueue.kt
- client/src/main/kotlin/de/justjanne/libquassel/client/util/CoroutineQueue.kt 28 additions, 0 deletions...lin/de/justjanne/libquassel/client/util/CoroutineQueue.kt
- client/src/test/kotlin/de/justjanne/libquassel/client/ClientTest.kt 97 additions, 0 deletions.../test/kotlin/de/justjanne/libquassel/client/ClientTest.kt
- client/src/test/kotlin/de/justjanne/libquassel/client/EndToEndTest.kt 0 additions, 238 deletions...est/kotlin/de/justjanne/libquassel/client/EndToEndTest.kt
- protocol/build.gradle.kts 2 additions, 0 deletionsprotocol/build.gradle.kts
- protocol/src/main/kotlin/de/justjanne/libquassel/protocol/exceptions/HandshakeException.kt 16 additions, 0 deletions...anne/libquassel/protocol/exceptions/HandshakeException.kt
- protocol/src/main/kotlin/de/justjanne/libquassel/protocol/io/CoroutineChannel.kt 1 addition, 2 deletions...n/de/justjanne/libquassel/protocol/io/CoroutineChannel.kt
- protocol/src/main/kotlin/de/justjanne/libquassel/protocol/io/CoroutineChannelState.kt 2 additions, 2 deletions...justjanne/libquassel/protocol/io/CoroutineChannelState.kt
- protocol/src/main/kotlin/de/justjanne/libquassel/protocol/io/FixedDeflaterOutputStream.kt 4 additions, 1 deletion...janne/libquassel/protocol/io/FixedDeflaterOutputStream.kt
- protocol/src/main/kotlin/de/justjanne/libquassel/protocol/io/ReadableWrappedChannel.kt 1 addition, 1 deletion...ustjanne/libquassel/protocol/io/ReadableWrappedChannel.kt
- protocol/src/main/kotlin/de/justjanne/libquassel/protocol/io/StreamChannel.kt 2 additions, 2 deletions...tlin/de/justjanne/libquassel/protocol/io/StreamChannel.kt
- protocol/src/main/kotlin/de/justjanne/libquassel/protocol/io/WritableWrappedChannel.kt 1 addition, 1 deletion...ustjanne/libquassel/protocol/io/WritableWrappedChannel.kt
Loading
Please register or sign in to comment