Skip to content

Commit

Permalink
Fixed build
Browse files Browse the repository at this point in the history
  • Loading branch information
mtmk committed Jan 23, 2024
1 parent 395e72b commit 4220250
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion src/NATS.Client.JetStream/Internal/NatsJSOrderedConsume.cs
Original file line number Diff line number Diff line change
Expand Up @@ -96,7 +96,7 @@ public NatsJSOrderedConsume(
// This channel is used to pass messages to the user from the subscription.
_userMsgs = Channel.CreateBounded<NatsJSMsg<TMsg>>(
Connection.GetChannelOpts(Connection.Opts, opts?.ChannelOpts),
msg => Connection.MessageDropped(this, _userMsgs?.Reader.Count ?? 0, msg.Msg));
msg => Connection.OnMessageDropped(this, _userMsgs?.Reader.Count ?? 0, msg.Msg));
Msgs = _userMsgs.Reader;

// Pull request channel is set as unbounded because we don't want to drop
Expand Down

0 comments on commit 4220250

Please sign in to comment.