| | | 1 | | // Copyright (c) ZeroC, Inc. |
| | | 2 | | |
| | | 3 | | #nullable enable |
| | | 4 | | |
| | | 5 | | namespace Ice.Internal; |
| | | 6 | | |
| | | 7 | | internal class FixedRequestHandler : RequestHandler |
| | | 8 | | { |
| | | 9 | | private readonly Reference _reference; |
| | | 10 | | private readonly bool _response; |
| | | 11 | | private readonly ConnectionI _connection; |
| | | 12 | | private readonly bool _compress; |
| | | 13 | | |
| | | 14 | | public int sendAsyncRequest(ProxyOutgoingAsyncBase outAsync) => |
| | 1 | 15 | | outAsync.invokeRemote(_connection, _compress, _response); |
| | | 16 | | |
| | | 17 | | public void asyncRequestCanceled(OutgoingAsyncBase outAsync, LocalException ex) => |
| | 0 | 18 | | _connection.asyncRequestCanceled(outAsync, ex); |
| | | 19 | | |
| | 0 | 20 | | public ConnectionI? getConnection() => _connection; |
| | | 21 | | |
| | 1 | 22 | | internal FixedRequestHandler(Reference reference, ConnectionI connection, bool compress) |
| | | 23 | | { |
| | 1 | 24 | | _reference = reference; |
| | 1 | 25 | | _response = _reference.isTwoway; |
| | 1 | 26 | | _connection = connection; |
| | 1 | 27 | | _compress = compress; |
| | 1 | 28 | | } |
| | | 29 | | } |