| name | samqtt-broker-tcp |
| description | Skill for the Samqtt.Broker.Tcp area of samqtt. 27 symbols across 4 files. |
Samqtt.Broker.Tcp
27 symbols | 4 files | Cohesion: 92%
When to Use
- Working with code in
src/
- Understanding how PublishAsync, SubscribeAsync, UnsubscribeAsync work
- Modifying samqtt.broker.tcp-related functionality
Key Files
| File | Symbols |
|---|
src/Samqtt.Broker.Tcp/MqttTcpClient.cs | PublishAsync, SubscribeAsync, UnsubscribeAsync, DisconnectAsync, SendConnectAsync (+16) |
src/Samqtt.Broker.Tcp/MqttConnector.cs | DisconnectAsync, DisposeAsync, DisposeAsyncCore, ConnectAsync |
src/Samqtt.Broker.Tcp/MqttSubscriber.cs | SubscribeAsync |
src/Samqtt.Broker.Tcp/MqttPublisher.cs | PublishAsync |
Entry Points
Start here when exploring this area:
PublishAsync (Method) — src/Samqtt.Broker.Tcp/MqttTcpClient.cs:62
SubscribeAsync (Method) — src/Samqtt.Broker.Tcp/MqttTcpClient.cs:91
UnsubscribeAsync (Method) — src/Samqtt.Broker.Tcp/MqttTcpClient.cs:107
DisconnectAsync (Method) — src/Samqtt.Broker.Tcp/MqttTcpClient.cs:113
DisposeAsync (Method) — src/Samqtt.Broker.Tcp/MqttTcpClient.cs:400
Key Symbols
| Symbol | Type | File | Line |
|---|
PublishAsync | Method | src/Samqtt.Broker.Tcp/MqttTcpClient.cs | 62 |
SubscribeAsync | Method | src/Samqtt.Broker.Tcp/MqttTcpClient.cs | 91 |
UnsubscribeAsync | Method | src/Samqtt.Broker.Tcp/MqttTcpClient.cs | 107 |
DisconnectAsync | Method | src/Samqtt.Broker.Tcp/MqttTcpClient.cs | 113 |
DisposeAsync | Method | src/Samqtt.Broker.Tcp/MqttTcpClient.cs | 400 |
SubscribeAsync | Method | src/Samqtt.Broker.Tcp/MqttSubscriber.cs | 70 |
PublishAsync | Method | src/Samqtt.Broker.Tcp/MqttPublisher.cs | 8 |
DisconnectAsync | Method | src/Samqtt.Broker.Tcp/MqttConnector.cs | 52 |
DisposeAsync | Method | src/Samqtt.Broker.Tcp/MqttConnector.cs | 64 |
ConnectAsync | Method | src/Samqtt.Broker.Tcp/MqttTcpClient.cs | 24 |
ConnectAsync | Method | src/Samqtt.Broker.Tcp/MqttConnector.cs | 17 |
SendConnectAsync | Method | src/Samqtt.Broker.Tcp/MqttTcpClient.cs | 222 |
WritePacketAsync | Method | src/Samqtt.Broker.Tcp/MqttTcpClient.cs | 303 |
BuildPublish | Method | src/Samqtt.Broker.Tcp/MqttTcpClient.cs | 317 |
BuildSubscribe | Method | src/Samqtt.Broker.Tcp/MqttTcpClient.cs | 337 |
BuildUnsubscribe | Method | src/Samqtt.Broker.Tcp/MqttTcpClient.cs | 354 |
WriteString | Method | src/Samqtt.Broker.Tcp/MqttTcpClient.cs | 370 |
WriteVarint | Method | src/Samqtt.Broker.Tcp/MqttTcpClient.cs | 378 |
NextPacketId | Method | src/Samqtt.Broker.Tcp/MqttTcpClient.cs | 392 |
DisposeAsyncCore | Method | src/Samqtt.Broker.Tcp/MqttConnector.cs | 70 |
Execution Flows
| Flow | Type | Steps |
|---|
DisposeAsync → WriteVarint | intra_community | 6 |
ConnectAsync → ReadByteAsync | intra_community | 5 |
ConnectAsync → ReadUInt16 | intra_community | 5 |
ConnectAsync → WritePacketAsync | cross_community | 5 |
DisposeAsync → WritePacketAsync | intra_community | 5 |
DisposeAsync → NextPacketId | intra_community | 5 |
SubscribeAsync → WriteVarint | intra_community | 4 |
PublishAsync → WriteVarint | intra_community | 4 |
ConnectAsync → WriteString | cross_community | 4 |
ConnectAsync → WriteVarint | cross_community | 4 |
How to Explore
gitnexus_context({name: "PublishAsync"}) — see callers and callees
gitnexus_query({query: "samqtt.broker.tcp"}) — find related execution flows
- Read key files listed above for implementation details