From 6a5292da5ee33081616113369de39f64e1b335ac Mon Sep 17 00:00:00 2001 From: Henrik Hautakoski Date: Wed, 29 Mar 2023 11:50:14 +0200 Subject: [PATCH] app/ship_processor.go: Return ShipProcessor object from SpawnProcessor() --- app/ship_processor.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/app/ship_processor.go b/app/ship_processor.go index e222c6a..f6746a4 100644 --- a/app/ship_processor.go +++ b/app/ship_processor.go @@ -33,7 +33,7 @@ type ShipProcessor struct { encode message.Encoder } -func SpawnProccessor(shClient *shipclient.Client, writer transport.Writer, abi *abi.AbiManager) { +func SpawnProccessor(shClient *shipclient.Client, writer transport.Writer, abi *abi.AbiManager) *ShipProcessor { processor := &ShipProcessor{ abi: abi, writer: writer, @@ -44,6 +44,8 @@ func SpawnProccessor(shClient *shipclient.Client, writer transport.Writer, abi * // Attach handlers shClient.BlockHandler = processor.processBlock shClient.TraceHandler = processor.processTraces + + return processor } func (processor *ShipProcessor) queueMessage(channel transport.Channel, payload []byte) bool {