Skip to content

Commit 12adc0d

Browse files
committed
Fix ZB PusherClient: add missing order/cancel channel dispatch
1 parent b68264f commit 12adc0d

1 file changed

Lines changed: 10 additions & 0 deletions

File tree

Connectors/ZB/Native/PusherClient.cs

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -89,6 +89,16 @@ private async ValueTask OnProcess(WebSocketMessage msg, CancellationToken cancel
8989
if (NewTrades is { } handler)
9090
await handler(channel.Remove(Channels.Trades, true), ((JToken)obj.data).DeserializeObject<IEnumerable<Trade>>(), cancellationToken);
9191
}
92+
else if (channel.EndsWithIgnoreCase(Channels.CancelOrder))
93+
{
94+
if (OrderChanged is { } handler)
95+
await handler((long)obj.no, ((JToken)obj.data).DeserializeObject<Order>(), cancellationToken);
96+
}
97+
else if (channel.EndsWithIgnoreCase(Channels.Order))
98+
{
99+
if (OrderChanged is { } handler)
100+
await handler((long)obj.no, ((JToken)obj.data).DeserializeObject<Order>(), cancellationToken);
101+
}
92102
else if (channel.EqualsIgnoreCase(Channels.GetOrders))
93103
{
94104
if (NewOrders is { } handler)

0 commit comments

Comments
 (0)