OperationExecutor.cs 1.9 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849
  1. /* Copyright 2010-2015 MongoDB Inc.
  2. *
  3. * Licensed under the Apache License, Version 2.0 (the "License");
  4. * you may not use this file except in compliance with the License.
  5. * You may obtain a copy of the License at
  6. *
  7. * http://www.apache.org/licenses/LICENSE-2.0
  8. *
  9. * Unless required by applicable law or agreed to in writing, software
  10. * distributed under the License is distributed on an "AS IS" BASIS,
  11. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  12. * See the License for the specific language governing permissions and
  13. * limitations under the License.
  14. */
  15. using System;
  16. using System.Collections.Generic;
  17. using System.Linq;
  18. using System.Text;
  19. using System.Threading;
  20. using System.Threading.Tasks;
  21. using MongoDB.Driver.Core.Bindings;
  22. using MongoDB.Driver.Core.Operations;
  23. namespace MongoDB.Driver
  24. {
  25. internal sealed class OperationExecutor : IOperationExecutor
  26. {
  27. public TResult ExecuteReadOperation<TResult>(IReadBinding binding, IReadOperation<TResult> operation, CancellationToken cancellationToken)
  28. {
  29. return operation.Execute(binding, cancellationToken);
  30. }
  31. public async Task<TResult> ExecuteReadOperationAsync<TResult>(IReadBinding binding, IReadOperation<TResult> operation, CancellationToken cancellationToken)
  32. {
  33. return await operation.ExecuteAsync(binding, cancellationToken).ConfigureAwait(false);
  34. }
  35. public TResult ExecuteWriteOperation<TResult>(IWriteBinding binding, IWriteOperation<TResult> operation, CancellationToken cancellationToken)
  36. {
  37. return operation.Execute(binding, cancellationToken);
  38. }
  39. public async Task<TResult> ExecuteWriteOperationAsync<TResult>(IWriteBinding binding, IWriteOperation<TResult> operation, CancellationToken cancellationToken)
  40. {
  41. return await operation.ExecuteAsync(binding, cancellationToken).ConfigureAwait(false);
  42. }
  43. }
  44. }