| /thrift-3.4.0/lib/netstd/Thrift/Protocol/ |
| D | TProtocolDecorator.cs | 42 …c override async Task WriteMessageBeginAsync(TMessage message, CancellationToken cancellationToken) in WriteMessageBeginAsync() argument
44 await _wrappedProtocol.WriteMessageBeginAsync(message, cancellationToken); in WriteMessageBeginAsync()
47 public override async Task WriteMessageEndAsync(CancellationToken cancellationToken) in WriteMessageEndAsync() argument
49 await _wrappedProtocol.WriteMessageEndAsync(cancellationToken); in WriteMessageEndAsync()
52 …lic override async Task WriteStructBeginAsync(TStruct @struct, CancellationToken cancellationToken)
54 await _wrappedProtocol.WriteStructBeginAsync(@struct, cancellationToken);
57 public override async Task WriteStructEndAsync(CancellationToken cancellationToken) in WriteStructEndAsync() argument
59 await _wrappedProtocol.WriteStructEndAsync(cancellationToken); in WriteStructEndAsync()
62 … public override async Task WriteFieldBeginAsync(TField field, CancellationToken cancellationToken) in WriteFieldBeginAsync() argument
64 await _wrappedProtocol.WriteFieldBeginAsync(field, cancellationToken); in WriteFieldBeginAsync()
[all …]
|
| D | TBinaryProtocol.cs | 55 …c override async Task WriteMessageBeginAsync(TMessage message, CancellationToken cancellationToken) in WriteMessageBeginAsync() argument
57 cancellationToken.ThrowIfCancellationRequested(); in WriteMessageBeginAsync()
62 await WriteI32Async((int) version, cancellationToken); in WriteMessageBeginAsync()
63 await WriteStringAsync(message.Name, cancellationToken); in WriteMessageBeginAsync()
64 await WriteI32Async(message.SeqID, cancellationToken); in WriteMessageBeginAsync()
68 await WriteStringAsync(message.Name, cancellationToken); in WriteMessageBeginAsync()
69 await WriteByteAsync((sbyte) message.Type, cancellationToken); in WriteMessageBeginAsync()
70 await WriteI32Async(message.SeqID, cancellationToken); in WriteMessageBeginAsync()
74 public override Task WriteMessageEndAsync(CancellationToken cancellationToken) in WriteMessageEndAsync() argument
76 cancellationToken.ThrowIfCancellationRequested(); in WriteMessageEndAsync()
[all …]
|
| D | TJSONProtocol.cs | 102 … protected async Task ReadJsonSyntaxCharAsync(byte[] bytes, CancellationToken cancellationToken) in ReadJsonSyntaxCharAsync() argument
104 var ch = await Reader.ReadAsync(cancellationToken); in ReadJsonSyntaxCharAsync()
114 private async Task WriteJsonStringAsync(byte[] bytes, CancellationToken cancellationToken) in WriteJsonStringAsync() argument
116 await Context.WriteConditionalDelimiterAsync(cancellationToken); in WriteJsonStringAsync()
117 await Trans.WriteAsync(TJSONProtocolConstants.Quote, cancellationToken); in WriteJsonStringAsync()
126 await Trans.WriteAsync(TJSONProtocolConstants.Backslash, cancellationToken); in WriteJsonStringAsync()
127 await Trans.WriteAsync(TJSONProtocolConstants.Backslash, cancellationToken); in WriteJsonStringAsync()
131 await Trans.WriteAsync(bytes, i, 1, cancellationToken); in WriteJsonStringAsync()
139 await Trans.WriteAsync(bytes, i, 1, cancellationToken); in WriteJsonStringAsync()
143 await Trans.WriteAsync(TJSONProtocolConstants.Backslash, cancellationToken); in WriteJsonStringAsync()
[all …]
|
| D | TCompactProtocol.cs | 126 …c override async Task WriteMessageBeginAsync(TMessage message, CancellationToken cancellationToken) in WriteMessageBeginAsync() argument
130 await Trans.WriteAsync(PreAllocatedBuffer, 0, 2, cancellationToken); in WriteMessageBeginAsync()
133 … await Trans.WriteAsync(PreAllocatedVarInt.bytes, 0, PreAllocatedVarInt.count, cancellationToken); in WriteMessageBeginAsync()
135 await WriteStringAsync(message.Name, cancellationToken); in WriteMessageBeginAsync()
138 public override Task WriteMessageEndAsync(CancellationToken cancellationToken) in WriteMessageEndAsync() argument
140 cancellationToken.ThrowIfCancellationRequested(); in WriteMessageEndAsync()
149 … public override Task WriteStructBeginAsync(TStruct @struct, CancellationToken cancellationToken)
151 cancellationToken.ThrowIfCancellationRequested();
159 public override Task WriteStructEndAsync(CancellationToken cancellationToken) in WriteStructEndAsync() argument
161 cancellationToken.ThrowIfCancellationRequested(); in WriteStructEndAsync()
[all …]
|
| D | TProtocol.cs | 106 …tract Task WriteMessageBeginAsync(TMessage message, CancellationToken cancellationToken = default); in WriteMessageBeginAsync() argument
108 public abstract Task WriteMessageEndAsync(CancellationToken cancellationToken = default); in WriteMessageEndAsync() argument
110 …bstract Task WriteStructBeginAsync(TStruct @struct, CancellationToken cancellationToken = default);
112 public abstract Task WriteStructEndAsync(CancellationToken cancellationToken = default); in WriteStructEndAsync() argument
114 …public abstract Task WriteFieldBeginAsync(TField field, CancellationToken cancellationToken = defa… in WriteFieldBeginAsync() argument
116 public abstract Task WriteFieldEndAsync(CancellationToken cancellationToken = default); in WriteFieldEndAsync() argument
118 public abstract Task WriteFieldStopAsync(CancellationToken cancellationToken = default); in WriteFieldStopAsync() argument
120 … public abstract Task WriteMapBeginAsync(TMap map, CancellationToken cancellationToken = default); in WriteMapBeginAsync() argument
122 public abstract Task WriteMapEndAsync(CancellationToken cancellationToken = default); in WriteMapEndAsync() argument
124 …public abstract Task WriteListBeginAsync(TList list, CancellationToken cancellationToken = default… in WriteListBeginAsync() argument
[all …]
|
| D | TMultiplexedProtocol.cs | 77 …c override async Task WriteMessageBeginAsync(TMessage message, CancellationToken cancellationToken) in WriteMessageBeginAsync() argument
83 …ssage($"{_serviceName}{Separator}{message.Name}", message.Type, message.SeqID), cancellationToken); in WriteMessageBeginAsync()
86 await base.WriteMessageBeginAsync(message, cancellationToken); in WriteMessageBeginAsync()
|
| /thrift-3.4.0/lib/netstd/Thrift/Protocol/Utilities/ |
| D | TProtocolUtil.cs | 27 …ic static async Task SkipAsync(TProtocol protocol, TType type, CancellationToken cancellationToken) in SkipAsync() argument
29 cancellationToken.ThrowIfCancellationRequested(); in SkipAsync()
37 await protocol.ReadBoolAsync(cancellationToken); in SkipAsync()
40 await protocol.ReadByteAsync(cancellationToken); in SkipAsync()
43 await protocol.ReadI16Async(cancellationToken); in SkipAsync()
46 await protocol.ReadI32Async(cancellationToken); in SkipAsync()
49 await protocol.ReadI64Async(cancellationToken); in SkipAsync()
52 await protocol.ReadDoubleAsync(cancellationToken); in SkipAsync()
56 await protocol.ReadBinaryAsync(cancellationToken); in SkipAsync()
59 await protocol.ReadUuidAsync(cancellationToken); in SkipAsync()
[all …]
|
| /thrift-3.4.0/lib/netstd/Thrift/ |
| D | TApplicationException.cs | 64 …Task<TApplicationException> ReadAsync(TProtocol inputProtocol, CancellationToken cancellationToken) in ReadAsync() argument
69 await inputProtocol.ReadStructBeginAsync(cancellationToken); in ReadAsync()
72 var field = await inputProtocol.ReadFieldBeginAsync(cancellationToken); in ReadAsync()
83 message = await inputProtocol.ReadStringAsync(cancellationToken); in ReadAsync()
87 … await TProtocolUtil.SkipAsync(inputProtocol, field.Type, cancellationToken); in ReadAsync()
93 … type = (ExceptionType) await inputProtocol.ReadI32Async(cancellationToken); in ReadAsync()
97 … await TProtocolUtil.SkipAsync(inputProtocol, field.Type, cancellationToken); in ReadAsync()
101 await TProtocolUtil.SkipAsync(inputProtocol, field.Type, cancellationToken); in ReadAsync()
105 await inputProtocol.ReadFieldEndAsync(cancellationToken); in ReadAsync()
108 await inputProtocol.ReadStructEndAsync(cancellationToken); in ReadAsync()
[all …]
|
| /thrift-3.4.0/lib/netstd/Thrift/Processor/ |
| D | TMultiplexedProcessor.cs | 41 …sync Task<bool> ProcessAsync(TProtocol iprot, TProtocol oprot, CancellationToken cancellationToken) in ProcessAsync() argument
43 cancellationToken.ThrowIfCancellationRequested(); in ProcessAsync()
47 var message = await iprot.ReadMessageBeginAsync(cancellationToken); in ProcessAsync()
52 "Message exType CALL or ONEWAY expected", cancellationToken); in ProcessAsync()
62 cancellationToken); in ProcessAsync()
72 cancellationToken); in ProcessAsync()
86 cancellationToken); in ProcessAsync()
106 string etxt, CancellationToken cancellationToken) in FailAsync() argument
112 await oprot.WriteMessageBeginAsync(newMessage, cancellationToken); in FailAsync()
113 await appex.WriteAsync(oprot, cancellationToken); in FailAsync()
[all …]
|
| /thrift-3.4.0/lib/netstd/Thrift/Transport/Client/ |
| D | TStreamTransport.cs | 55 public override Task OpenAsync(CancellationToken cancellationToken) in OpenAsync() argument
57 cancellationToken.ThrowIfCancellationRequested(); in OpenAsync()
76 …alueTask<int> ReadAsync(byte[] buffer, int offset, int length, CancellationToken cancellationToken) in ReadAsync() argument
85 return await InputStream.ReadAsync(buffer, offset, length, cancellationToken); in ReadAsync()
87 … return await InputStream.ReadAsync(new Memory<byte>(buffer, offset, length), cancellationToken); in ReadAsync()
91 …e async Task WriteAsync(byte[] buffer, int offset, int length, CancellationToken cancellationToken) in WriteAsync() argument
100 await OutputStream.WriteAsync(buffer, offset, length, cancellationToken); in WriteAsync()
102 await OutputStream.WriteAsync(buffer.AsMemory(offset, length), cancellationToken); in WriteAsync()
106 public override async Task FlushAsync(CancellationToken cancellationToken) in FlushAsync() argument
108 await OutputStream.FlushAsync(cancellationToken); in FlushAsync()
|
| D | TNamedPipeTransport.cs | 49 public override async Task OpenAsync(CancellationToken cancellationToken) in OpenAsync() argument
56 await PipeStream.ConnectAsync( ConnectTimeout, cancellationToken); in OpenAsync()
71 …alueTask<int> ReadAsync(byte[] buffer, int offset, int length, CancellationToken cancellationToken) in ReadAsync() argument
80 var numRead = await PipeStream.ReadAsync(buffer, offset, length, cancellationToken); in ReadAsync()
82 … numRead = await PipeStream.ReadAsync(new Memory<byte>(buffer, offset, length), cancellationToken); in ReadAsync()
88 …e async Task WriteAsync(byte[] buffer, int offset, int length, CancellationToken cancellationToken) in WriteAsync() argument
102 await PipeStream.WriteAsync(buffer, offset, nBytes, cancellationToken); in WriteAsync()
104 await PipeStream.WriteAsync(buffer.AsMemory(offset, nBytes), cancellationToken); in WriteAsync()
112 public override async Task FlushAsync(CancellationToken cancellationToken) in FlushAsync() argument
114 await PipeStream.FlushAsync(cancellationToken); in FlushAsync()
|
| D | THttpTransport.cs | 115 public override Task OpenAsync(CancellationToken cancellationToken) in OpenAsync() argument
117 cancellationToken.ThrowIfCancellationRequested(); in OpenAsync()
142 …alueTask<int> ReadAsync(byte[] buffer, int offset, int length, CancellationToken cancellationToken) in ReadAsync() argument
144 cancellationToken.ThrowIfCancellationRequested(); in ReadAsync()
154 var ret = await _inputStream.ReadAsync(buffer, offset, length, cancellationToken); in ReadAsync()
156 …ar ret = await _inputStream.ReadAsync(new Memory<byte>(buffer, offset, length), cancellationToken); in ReadAsync()
172 …e async Task WriteAsync(byte[] buffer, int offset, int length, CancellationToken cancellationToken) in WriteAsync() argument
174 cancellationToken.ThrowIfCancellationRequested(); in WriteAsync()
177 await _outputStream.WriteAsync(buffer, offset, length, cancellationToken); in WriteAsync()
179 await _outputStream.WriteAsync(buffer.AsMemory(offset, length), cancellationToken); in WriteAsync()
[all …]
|
| D | TMemoryBufferTransport.cs | 85 public override Task OpenAsync(CancellationToken cancellationToken) in OpenAsync() argument
87 cancellationToken.ThrowIfCancellationRequested(); in OpenAsync()
122 …alueTask<int> ReadAsync(byte[] buffer, int offset, int length, CancellationToken cancellationToken) in ReadAsync() argument
131 public override Task WriteAsync(byte[] buffer, CancellationToken cancellationToken) in WriteAsync() argument
133 return WriteAsync(buffer, 0, buffer.Length, cancellationToken); in WriteAsync()
136 …override Task WriteAsync(byte[] buffer, int offset, int count, CancellationToken cancellationToken) in WriteAsync() argument
145 public override Task FlushAsync(CancellationToken cancellationToken) in FlushAsync() argument
147 cancellationToken.ThrowIfCancellationRequested(); in FlushAsync()
|
| /thrift-3.4.0/lib/netstd/Tests/Thrift.PublicInterfaces.Compile.Tests/Impl/Thrift5253/ |
| D | MyService.cs | 29 …yncProcessor> AsyncProcessor_(AsyncProcessor? input, CancellationToken cancellationToken = default)
34 … public Task<BrokenResult> Broken(BrokenArgs? input, CancellationToken cancellationToken = default)
39 public Task<Client> Client_(Client? input, CancellationToken cancellationToken = default)
41 _ = cancellationToken;
45 public Task<IAsync> IAsync_(IAsync? input, CancellationToken cancellationToken = default)
50 …nalStructs> InternalStructs_(InternalStructs? input, CancellationToken cancellationToken = default)
55 public Task TestAsync(CancellationToken cancellationToken = default) in TestAsync() argument
60 public Task TestXsync(CancellationToken cancellationToken = default) in TestXsync() argument
65 … public Task<WorksRslt> Works(WorksArrrgs? input, CancellationToken cancellationToken = default)
|
| /thrift-3.4.0/lib/netstd/Thrift/Transport/Layered/ |
| D | TFramedTransport.cs | 54 public override async Task OpenAsync(CancellationToken cancellationToken) in OpenAsync() argument
58 await InnerTransport.OpenAsync(cancellationToken); in OpenAsync()
68 …alueTask<int> ReadAsync(byte[] buffer, int offset, int length, CancellationToken cancellationToken) in ReadAsync() argument
81 await ReadFrameAsync(cancellationToken); in ReadAsync()
84 return await ReadBuffer.ReadAsync(buffer, offset, length, cancellationToken); in ReadAsync()
87 private async ValueTask ReadFrameAsync(CancellationToken cancellationToken) in ReadFrameAsync() argument
90 await InnerTransport.ReadAllAsync(HeaderBuf, 0, HeaderSize, cancellationToken); in ReadFrameAsync()
101 await InnerTransport.ReadAllAsync(bufSegment.Array, 0, size, cancellationToken); in ReadFrameAsync()
104 …e async Task WriteAsync(byte[] buffer, int offset, int length, CancellationToken cancellationToken) in WriteAsync() argument
116 await FlushAsync(cancellationToken); in WriteAsync()
[all …]
|
| D | TBufferedTransport.cs | 72 public override async Task OpenAsync(CancellationToken cancellationToken) in OpenAsync() argument
76 await InnerTransport.OpenAsync(cancellationToken); in OpenAsync()
86 …alueTask<int> ReadAsync(byte[] buffer, int offset, int length, CancellationToken cancellationToken) in ReadAsync() argument
101 return await ReadBuffer.ReadAsync(buffer, offset, length, cancellationToken); in ReadAsync()
108 return await InnerTransport.ReadAsync(buffer, offset, length, cancellationToken); in ReadAsync()
114 ….Length = await InnerTransport.ReadAsync(bufSegment.Array, 0, bufSegment.Count, cancellationToken); in ReadAsync()
118 return await ReadBuffer.ReadAsync(buffer, offset, length, cancellationToken); in ReadAsync()
122 …e async Task WriteAsync(byte[] buffer, int offset, int length, CancellationToken cancellationToken) in WriteAsync() argument
137 … await InnerTransport.WriteAsync(bufSegment.Array, 0, bufSegment.Count, cancellationToken); in WriteAsync()
145 await WriteBuffer.WriteAsync(buffer, offset, length, cancellationToken); in WriteAsync()
[all …]
|
| /thrift-3.4.0/lib/netstd/Thrift/Transport/ |
| D | TTransport.cs | 45 public async ValueTask<bool> PeekAsync(CancellationToken cancellationToken) in PeekAsync() argument
62 var bytes = await ReadAsync(_peekBuffer, 0, 1, cancellationToken); in PeekAsync()
78 public abstract Task OpenAsync(CancellationToken cancellationToken = default); in OpenAsync() argument
108 …lueTask<int> ReadAsync(byte[] buffer, int offset, int length, CancellationToken cancellationToken); in ReadAsync() argument
110 …eTask<int> ReadAllAsync(byte[] buffer, int offset, int length, CancellationToken cancellationToken) in ReadAllAsync() argument
112 cancellationToken.ThrowIfCancellationRequested(); in ReadAllAsync()
135 var numBytes = await ReadAsync(buffer, offset, remaining, cancellationToken); in ReadAllAsync()
153 public virtual async Task WriteAsync(byte[] buffer, CancellationToken cancellationToken) in WriteAsync() argument
163 …stract Task WriteAsync(byte[] buffer, int offset, int length, CancellationToken cancellationToken); in WriteAsync() argument
166 public abstract Task FlushAsync(CancellationToken cancellationToken); in FlushAsync() argument
|
| /thrift-3.4.0/lib/netstd/Thrift/Server/ |
| D | TSimpleAsyncServer.cs | 86 public override async Task ServeAsync(CancellationToken cancellationToken) in ServeAsync() argument
88 ServerCancellationToken = cancellationToken; in ServeAsync()
103 await ServerEventHandler.PreServeAsync(cancellationToken); in ServeAsync()
109 … using (TTransport client = await ServerTransport.AcceptAsync(cancellationToken)) in ServeAsync()
155 var cancellationToken = ServerCancellationToken; in ExecuteAsync()
175 …xt = await ServerEventHandler.CreateContextAsync(inputProtocol, outputProtocol, cancellationToken); in ExecuteAsync()
178 while (!(stop || cancellationToken.IsCancellationRequested)) in ExecuteAsync()
180 if (!await inputTransport.PeekAsync(cancellationToken)) in ExecuteAsync()
188 …await ServerEventHandler.ProcessContextAsync(connectionContext, inputTransport, cancellationToken); in ExecuteAsync()
191 … if (!await processor.ProcessAsync(inputProtocol, outputProtocol, cancellationToken)) in ExecuteAsync()
[all …]
|
| D | TThreadPoolAsyncServer.cs | 155 public override async Task ServeAsync(CancellationToken cancellationToken) in ServeAsync() argument
157 ServerCancellationToken = cancellationToken; in ServeAsync()
172 await ServerEventHandler.PreServeAsync(cancellationToken); in ServeAsync()
178 TTransport client = await ServerTransport.AcceptAsync(cancellationToken); in ServeAsync()
179 …_ = Task.Run(async () => await ExecuteAsync(client), cancellationToken); // intentionally ignorin… in ServeAsync()
222 var cancellationToken = ServerCancellationToken; in ExecuteAsync()
243 …xt = await ServerEventHandler.CreateContextAsync(inputProtocol, outputProtocol, cancellationToken); in ExecuteAsync()
246 while (!(stop || cancellationToken.IsCancellationRequested)) in ExecuteAsync()
248 if (!await inputTransport.PeekAsync(cancellationToken)) in ExecuteAsync()
256 …await ServerEventHandler.ProcessContextAsync(connectionContext, inputTransport, cancellationToken); in ExecuteAsync()
[all …]
|
| D | TServerEventHandler.cs | 44 Task PreServeAsync(CancellationToken cancellationToken); in PreServeAsync() argument
49 …object> CreateContextAsync(TProtocol input, TProtocol output, CancellationToken cancellationToken); in CreateContextAsync() argument
55 CancellationToken cancellationToken); in DeleteContextAsync() argument
60 …ocessContextAsync(object serverContext, TTransport transport, CancellationToken cancellationToken); in ProcessContextAsync() argument
|
| /thrift-3.4.0/test/netstd/Server/ |
| D | TestServer.cs | 178 public Task PreServeAsync(CancellationToken cancellationToken) in PreServeAsync() argument
184 …object?> CreateContextAsync(TProtocol input, TProtocol output, CancellationToken cancellationToken) in CreateContextAsync() argument
190 …Async(object serverContext, TProtocol input, TProtocol output, CancellationToken cancellationToken) in DeleteContextAsync() argument
196 …rocessContextAsync(object serverContext, TTransport transport, CancellationToken cancellationToken) in ProcessContextAsync() argument
226 public Task testVoid(CancellationToken cancellationToken) in testVoid() argument
232 public Task<string> testString(string? thing, CancellationToken cancellationToken) in testString() argument
238 public Task<bool> testBool(bool thing, CancellationToken cancellationToken) in testBool() argument
244 public Task<sbyte> testByte(sbyte thing, CancellationToken cancellationToken) in testByte() argument
250 public Task<int> testI32(int thing, CancellationToken cancellationToken) in testI32() argument
256 public Task<long> testI64(long thing, CancellationToken cancellationToken) in testI64() argument
[all …]
|
| /thrift-3.4.0/lib/netstd/Thrift/Transport/Server/ |
| D | TNamedPipeServerTransport.cs | 321 …override async ValueTask<TTransport> AcceptImplementationAsync(CancellationToken cancellationToken) in AcceptImplementationAsync() argument
334 …sk.Run(async () => await pair.Stream.WaitForConnectionAsync(cancellationToken), cancellationToken); in AcceptImplementationAsync()
343 var index = Task.WaitAny(tasks.ToArray(), cancellationToken); in AcceptImplementationAsync()
379 public override Task OpenAsync(CancellationToken cancellationToken) in OpenAsync() argument
381 cancellationToken.ThrowIfCancellationRequested(); in OpenAsync()
396 …alueTask<int> ReadAsync(byte[] buffer, int offset, int length, CancellationToken cancellationToken) in ReadAsync() argument
405 … var numBytes = await PipeStream.ReadAsync(buffer, offset, length, cancellationToken); in ReadAsync()
407 … var numBytes = await PipeStream.ReadAsync(buffer.AsMemory(offset, length), cancellationToken); in ReadAsync()
413 …e async Task WriteAsync(byte[] buffer, int offset, int length, CancellationToken cancellationToken) in WriteAsync() argument
427 await PipeStream.WriteAsync(buffer.AsMemory(offset, nBytes), cancellationToken); in WriteAsync()
[all …]
|
| D | TServerTransport.cs | 39 …act ValueTask<TTransport> AcceptImplementationAsync(CancellationToken cancellationToken = default); in AcceptImplementationAsync() argument
41 … public async ValueTask<TTransport> AcceptAsync(CancellationToken cancellationToken = default) in AcceptAsync() argument
43 var transport = await AcceptImplementationAsync(cancellationToken); in AcceptAsync()
|
| /thrift-3.4.0/tutorial/netstd/Client/ |
| D | Program.cs | 119 private static async Task RunAsync(string[] args, CancellationToken cancellationToken) in RunAsync() argument
137 var task = RunClientAsync(protocol, mplex, cancellationToken); in RunAsync()
141 Task.WaitAll(tasks,cancellationToken); in RunAsync()
302 … async Task RunClientAsync(TProtocol protocol, bool multiplex, CancellationToken cancellationToken) in RunClientAsync() argument
312 await ExecuteCalculatorClientOperations(client, cancellationToken); in RunClientAsync()
329 …k ExecuteCalculatorClientOperations( Calculator.Client client, CancellationToken cancellationToken) in ExecuteCalculatorClientOperations() argument
331 await client.OpenTransportAsync(cancellationToken); in ExecuteCalculatorClientOperations()
336 await client.ping(cancellationToken); in ExecuteCalculatorClientOperations()
339 var sum = await client.add(1, 1, cancellationToken); in ExecuteCalculatorClientOperations()
352 await client.calculate(1, work, cancellationToken); in ExecuteCalculatorClientOperations()
[all …]
|
| /thrift-3.4.0/tutorial/netstd/Server/ |
| D | Program.cs | 124 private static async Task RunAsync(string[] args, CancellationToken cancellationToken) in RunAsync() argument
135 new HttpServerSample().Run(cancellationToken); in RunAsync()
139 …urationAsync(selectedTransport, selectedBuffering, selectedProtocol, multiplex, cancellationToken); in RunAsync()
189 …sport, Buffering buffering, Protocol protocol, bool multiplex, CancellationToken cancellationToken) in RunSelectedConfigurationAsync() argument
249 await server.ServeAsync(cancellationToken); in RunSelectedConfigurationAsync()
317 public void Run(CancellationToken cancellationToken) in Run() argument
334 host.RunAsync(cancellationToken).GetAwaiter().GetResult(); in Run()
379 CancellationToken cancellationToken) in getStruct() argument
385 public async Task ping(CancellationToken cancellationToken) in ping() argument
391 public async Task<int> add(int num1, int num2, CancellationToken cancellationToken) in add() argument
[all …]
|
