anygatecloud/strom
2
1
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

my code broke after i changed this last time and this fixed it

Browse Source
This commit is contained in:
Admin Else
2026-04-03 19:01:33 +02:00
parent a3a3c3714e
commit fb69fd93ec
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
proto/connection.go
+3 -1
View File
@@ -119,6 +119,8 @@ func (c *Conn) SetProtocolVersion(version int32) (err error) {
// ActivateReceiveRoutine activates the receive-routine. // ActivateReceiveRoutine activates the receive-routine.
// It ensures that the receive-routine is only started once and creates a buffered channel for packet handling. // It ensures that the receive-routine is only started once and creates a buffered channel for packet handling.
func (c *Conn) ActivateReceiveRoutine() (chSending <-chan any) { func (c *Conn) ActivateReceiveRoutine() (chSending <-chan any) {
// This expects you to start a new routine when switching into play state
spamLoginTick := c.State() != proto_base.Play
ch := make(chan any, BufferNPackets) ch := make(chan any, BufferNPackets)
go func() { go func() {
ctx := c.Ctx // this prevents c.Ctx being reassigned ctx := c.Ctx // this prevents c.Ctx being reassigned
@@ -127,7 +129,7 @@ func (c *Conn) ActivateReceiveRoutine() (chSending <-chan any) {
case <-ctx.Done(): case <-ctx.Done():
return return
default: default:
if c.State() != proto_base.Play { if spamLoginTick {
ch <- LoginTick{} ch <- LoginTick{}
} else { } else {
packet, err := c.Receive() packet, err := c.Receive()