blob: 36498b620f6190bf2b919cc94e779c8c8172f93b [file] [log] [blame]
/*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
namespace DotPulsar.Internal.Requests
{
using DotPulsar.Internal.Abstractions;
using System;
using System.Diagnostics.CodeAnalysis;
public struct SendRequest : IRequest
{
private readonly ulong _producerId;
private readonly ulong _sequenceId;
public SendRequest(ulong producerId, ulong sequenceId)
{
_producerId = producerId;
_sequenceId = sequenceId;
}
public bool SenderIsConsumer(ulong consumerId)
=> false;
public bool SenderIsProducer(ulong producerId)
=> _producerId == producerId;
#if NETSTANDARD2_0
public bool Equals(IRequest other)
#else
public bool Equals([AllowNull] IRequest other)
#endif
{
if (other is SendRequest request)
return _producerId.Equals(request._producerId) && _sequenceId.Equals(request._sequenceId);
return false;
}
public override int GetHashCode()
=> HashCode.Combine(_producerId, _sequenceId);
}
}