diff options
author | Tim Emiola <tbetbetbe@users.noreply.github.com> | 2015-05-05 14:45:04 -0700 |
---|---|---|
committer | Tim Emiola <tbetbetbe@users.noreply.github.com> | 2015-05-05 14:45:04 -0700 |
commit | fde356c98e4c29148e7d5d0aa561be34235356d9 (patch) | |
tree | 60916341271674509b70048540ef0ce4dc43be61 /src/csharp/Grpc.Core/AsyncClientStreamingCall.cs | |
parent | e785be8a93a472a93ca6e88fdad6dcc1abbde19a (diff) | |
parent | a8447711be717a53fc52a3a14dd33fdb85fc80f2 (diff) |
Merge pull request #1445 from jtattermusch/csharp_new_api
A new C# API based on async/await
Diffstat (limited to 'src/csharp/Grpc.Core/AsyncClientStreamingCall.cs')
-rw-r--r-- | src/csharp/Grpc.Core/AsyncClientStreamingCall.cs | 101 |
1 files changed, 101 insertions, 0 deletions
diff --git a/src/csharp/Grpc.Core/AsyncClientStreamingCall.cs b/src/csharp/Grpc.Core/AsyncClientStreamingCall.cs new file mode 100644 index 0000000000..e81ce01ebb --- /dev/null +++ b/src/csharp/Grpc.Core/AsyncClientStreamingCall.cs @@ -0,0 +1,101 @@ +#region Copyright notice and license + +// Copyright 2015, Google Inc. +// All rights reserved. +// +// Redistribution and use in source and binary forms, with or without +// modification, are permitted provided that the following conditions are +// met: +// +// * Redistributions of source code must retain the above copyright +// notice, this list of conditions and the following disclaimer. +// * Redistributions in binary form must reproduce the above +// copyright notice, this list of conditions and the following disclaimer +// in the documentation and/or other materials provided with the +// distribution. +// * Neither the name of Google Inc. nor the names of its +// contributors may be used to endorse or promote products derived from +// this software without specific prior written permission. +// +// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS +// "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT +// LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR +// A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT +// OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, +// SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT +// LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, +// DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY +// THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT +// (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE +// OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. + +#endregion + +using System; +using System.Runtime.CompilerServices; +using System.Threading.Tasks; + +namespace Grpc.Core +{ + /// <summary> + /// Return type for client streaming calls. + /// </summary> + public struct AsyncClientStreamingCall<TRequest, TResponse> + { + readonly IClientStreamWriter<TRequest> requestStream; + readonly Task<TResponse> result; + + public AsyncClientStreamingCall(IClientStreamWriter<TRequest> requestStream, Task<TResponse> result) + { + this.requestStream = requestStream; + this.result = result; + } + + /// <summary> + /// Writes a request to RequestStream. + /// </summary> + public Task Write(TRequest message) + { + return requestStream.Write(message); + } + + /// <summary> + /// Closes the RequestStream. + /// </summary> + public Task Close() + { + return requestStream.Close(); + } + + /// <summary> + /// Asynchronous call result. + /// </summary> + public Task<TResponse> Result + { + get + { + return this.result; + } + } + + /// <summary> + /// Async stream to send streaming requests. + /// </summary> + public IClientStreamWriter<TRequest> RequestStream + { + get + { + return requestStream; + } + } + + /// <summary> + /// Allows awaiting this object directly. + /// </summary> + /// <returns></returns> + public TaskAwaiter<TResponse> GetAwaiter() + { + return result.GetAwaiter(); + } + } +} |