ScoringEventLoop.cs
1 //
2 // Copyright (c) Microsoft. All rights reserved.
3 // Licensed under the MIT license.
4 //
5 // Microsoft Bot Framework: http://botframework.com
6 //
7 // Bot Builder SDK GitHub:
8 // https://github.com/Microsoft/BotBuilder
9 //
10 // Copyright (c) Microsoft Corporation
11 // All rights reserved.
12 //
13 // MIT License:
14 // Permission is hereby granted, free of charge, to any person obtaining
15 // a copy of this software and associated documentation files (the
16 // "Software"), to deal in the Software without restriction, including
17 // without limitation the rights to use, copy, modify, merge, publish,
18 // distribute, sublicense, and/or sell copies of the Software, and to
19 // permit persons to whom the Software is furnished to do so, subject to
20 // the following conditions:
21 //
22 // The above copyright notice and this permission notice shall be
23 // included in all copies or substantial portions of the Software.
24 //
25 // THE SOFTWARE IS PROVIDED ""AS IS"", WITHOUT WARRANTY OF ANY KIND,
26 // EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
27 // MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
28 // NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE
29 // LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
30 // OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
31 // WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
32 //
33 
34 using System;
35 using System.Collections;
36 using System.Collections.Generic;
37 using System.Linq;
38 using System.Text;
39 using System.Threading;
40 using System.Threading.Tasks;
41 
44 using Microsoft.Bot.Connector;
46 
47 namespace Microsoft.Bot.Builder.Dialogs.Internals
48 {
53  public sealed class ScoringEventLoop<Score> : IEventLoop
54  {
55  private readonly IEventLoop innerLoop;
56  private readonly IEventProducer<IActivity> innerProducer;
57  private readonly IEventConsumer<IActivity> consumer;
58  private readonly IScorable<IActivity, Score> scorable;
60  {
61  SetField.NotNull(out this.innerLoop, nameof(innerLoop), innerLoop);
62  SetField.NotNull(out this.innerProducer, nameof(innerProducer), innerProducer);
63  SetField.NotNull(out this.consumer, nameof(consumer), consumer);
64  SetField.NotNull(out this.scorable, nameof(scorable), scorable);
65  }
66 
67  async Task IEventLoop.PollAsync(CancellationToken token)
68  {
69  // for proactive dialogs
70  await this.innerLoop.PollAsync(token);
71 
72  IActivity activity;
73  while (this.consumer.TryPull(out activity))
74  {
75  // for event wait completions
76  await this.innerLoop.PollAsync(token);
77 
78  if (await this.scorable.TryPostAsync(activity, token))
79  {
80  }
81  else
82  {
83  this.innerProducer.Post(activity);
84  }
85 
86  // for normal wait completions
87  await this.innerLoop.PollAsync(token);
88  }
89  }
90  }
91 }
Namespace for the Microsoft Bot Connector SDK.
Namespace for scorable interfaces, classes and compositions.
Namespace for internal machinery that is not useful for most developers and may change in the future...
This event loop dispatches incoming activities to a scorable action, and then if the scorable action ...
Shared properties for all activities
Definition: IActivity.cs:9
Task PollAsync(CancellationToken token)
Poll the target for any work to be done.
ScoringEventLoop(IEventLoop innerLoop, IEventProducer< IActivity > innerProducer, IEventConsumer< IActivity > consumer, IScorable< IActivity, Score > scorable)
Namespace for the internal fibers machinery that is not useful for most developers and may change in ...
Root namespace for the Microsoft Bot Builder SDK.